Explorar o código

events.State: always instantiate a Worker for offline nodes (to fix an AttributeError in on_node_leave for worker.hostname)

Brodie Rao %!s(int64=11) %!d(string=hai) anos
pai
achega
249da1680b
Modificáronse 1 ficheiros con 2 adicións e 6 borrados
  1. 2 6
      celery/events/state.py

+ 2 - 6
celery/events/state.py

@@ -519,12 +519,8 @@ class State(object):
                     try:
                         worker, created = get_worker(hostname), False
                     except KeyError:
-                        if subject == 'offline':
-                            worker, created = None, False
-                        else:
-                            worker = workers[hostname] = Worker(hostname)
-                    if worker:
-                        worker.event(subject, timestamp, local_received, event)
+                        worker = workers[hostname] = Worker(hostname)
+                    worker.event(subject, timestamp, local_received, event)
                     if on_node_join and (created or subject == 'online'):
                         on_node_join(worker)
                     if on_node_leave and subject == 'offline':