Browse Source

Fixes deep dicts in chain

Ask Solem 10 years ago
parent
commit
230b1ff7cb
1 changed files with 5 additions and 1 deletions
  1. 5 1
      celery/canvas.py

+ 5 - 1
celery/canvas.py

@@ -468,7 +468,11 @@ class chain(Signature):
 
     @classmethod
     def from_dict(self, d, app=None):
-        return chain(*d['kwargs']['tasks'], app=app, **d['options'])
+        tasks = d['kwargs']['tasks']
+        if tasks:
+            # First task must be signature object to get app
+            tasks[0] = maybe_signature(tasks[0], app=app)
+        return chain(*tasks, app=app, **d['options'])
 
     @property
     def app(self):