Explorar o código

Fixes fallback chord result passing bug. Closes #1216

Ask Solem %!s(int64=12) %!d(string=hai) anos
pai
achega
d2f5a9a1e2
Modificáronse 1 ficheiros con 1 adicións e 1 borrados
  1. 1 1
      celery/backends/base.py

+ 1 - 1
celery/backends/base.py

@@ -280,7 +280,7 @@ class BaseBackend(object):
 
 
     def fallback_chord_unlock(self, group_id, body, result=None,
     def fallback_chord_unlock(self, group_id, body, result=None,
                               countdown=1, **kwargs):
                               countdown=1, **kwargs):
-        kwargs['result'] = [r.id for r in result]
+        kwargs['result'] = [r.serializable() for r in result]
         self.app.tasks['celery.chord_unlock'].apply_async(
         self.app.tasks['celery.chord_unlock'].apply_async(
             (group_id, body, ), kwargs, countdown=countdown,
             (group_id, body, ), kwargs, countdown=countdown,
         )
         )