Explorar el Código

Adds worker_pid to TaskRequest.info()

Ask Solem hace 14 años
padre
commit
d4a46861e7
Se han modificado 1 ficheros con 2 adiciones y 1 borrados
  1. 2 1
      celery/worker/job.py

+ 2 - 1
celery/worker/job.py

@@ -553,7 +553,8 @@ class TaskRequest(object):
                 "hostname": self.hostname,
                 "time_start": self.time_start,
                 "acknowledged": self.acknowledged,
-                "delivery_info": self.delivery_info}
+                "delivery_info": self.delivery_info,
+                "worker_pid": self.worker_pid}
 
     def shortinfo(self):
         return "%s[%s]%s%s" % (