Quellcode durchsuchen

Delayed tasks break celerev due to no worker attached to the task.

Matt Williamson vor 13 Jahren
Ursprung
Commit
3a8d89977e
1 geänderte Dateien mit 2 neuen und 1 gelöschten Zeilen
  1. 2 1
      celery/events/cursesmon.py

+ 2 - 1
celery/events/cursesmon.py

@@ -314,8 +314,9 @@ class CursesMonitor(object):
         timestamp = datetime.utcfromtimestamp(
                         task.timestamp or time.time())
         timef = timestamp.strftime("%H:%M:%S")
+        hostname = task.worker.hostname if task.worker else '*NONE*'
         line = self.format_row(task.uuid, task.name,
-                               task.worker.hostname,
+                               hostname,
                                timef, task.state)
         self.win.addstr(lineno, LEFT_BORDER_OFFSET, line, attr)