Jelajahi Sumber

Events: Fields not passed by .send() (fixes the uuid keyerrors in celerymon)

Ask Solem 15 tahun lalu
induk
melakukan
910c351a93
1 mengubah file dengan 1 tambahan dan 1 penghapusan
  1. 1 1
      celery/events.py

+ 1 - 1
celery/events.py

@@ -55,7 +55,7 @@ class EventDispatcher(object):
 
         self._lock.acquire()
         try:
-            self.publisher.send(Event(type, hostname=self.hostname))
+            self.publisher.send(Event(type, hostname=self.hostname, **fields))
         finally:
             self._lock.release()