Parcourir la source

celeryev: kwargs can't be unicode

Ask Solem il y a 15 ans
Parent
commit
b37d862d63
1 fichiers modifiés avec 2 ajouts et 0 suppressions
  1. 2 0
      celery/events/state.py

+ 2 - 0
celery/events/state.py

@@ -137,6 +137,8 @@ class State(object):
         worker = self.get_worker(hostname)
         task = self.get_task(uuid, worker=worker)
         handler = getattr(task, type)
+        fields = dict((key.encode("utf-8"), value)
+                        for key, value in fields.items())
         if type == "received":
             self.task_count += 1
         if handler: