Bladeren bron

TaskSet must ensure task lists are subtasks, not dict after serialization.

Closes #513.  Thanks to zeeshanlakhani.
Ask Solem 13 jaren geleden
bovenliggende
commit
955dbeb760
1 gewijzigde bestanden met toevoegingen van 1 en 1 verwijderingen
  1. 1 1
      celery/task/sets.py

+ 1 - 1
celery/task/sets.py

@@ -139,7 +139,7 @@ class TaskSet(UserList):
         self.app = app_or_default(app)
         self.app = app_or_default(app)
         if task is not None:
         if task is not None:
             if hasattr(task, "__iter__"):
             if hasattr(task, "__iter__"):
-                tasks = task
+                tasks = [subtask(t) for t in task]
             else:
             else:
                 # Previously TaskSet only supported applying one kind of task.
                 # Previously TaskSet only supported applying one kind of task.
                 # the signature then was TaskSet(task, arglist),
                 # the signature then was TaskSet(task, arglist),