|
|
@ -265,13 +265,15 @@ class Worker(object):
|
|
|
|
now = utcnow()
|
|
|
|
now = utcnow()
|
|
|
|
now_in_string = utcformat(now)
|
|
|
|
now_in_string = utcformat(now)
|
|
|
|
self.birth_date = now
|
|
|
|
self.birth_date = now
|
|
|
|
p.hset(key, 'birth', now_in_string)
|
|
|
|
p.hmset(key, {
|
|
|
|
p.hset(key, 'last_heartbeat', now_in_string)
|
|
|
|
'birth': now_in_string,
|
|
|
|
p.hset(key, 'queues', queues)
|
|
|
|
'last_heartbeat': now_in_string,
|
|
|
|
p.hset(key, 'pid', self.pid)
|
|
|
|
'queues': queues,
|
|
|
|
p.hset(key, 'hostname', self.hostname)
|
|
|
|
'pid': self.pid,
|
|
|
|
p.hset(key, 'version', self.version)
|
|
|
|
'hostname': self.hostname,
|
|
|
|
p.hset(key, 'python_version', self.python_version)
|
|
|
|
'version': self.version,
|
|
|
|
|
|
|
|
'python_version': self.python_version,
|
|
|
|
|
|
|
|
})
|
|
|
|
worker_registration.register(self, p)
|
|
|
|
worker_registration.register(self, p)
|
|
|
|
p.expire(key, self.default_worker_ttl)
|
|
|
|
p.expire(key, self.default_worker_ttl)
|
|
|
|
p.execute()
|
|
|
|
p.execute()
|
|
|
|