浏览代码

Fix ValueError in chord with single task header (#3608)

Viktor Holmqvist 8 年之前
父节点
当前提交
fe2c47d4e6
共有 1 个文件被更改,包括 1 次插入1 次删除
  1. 1 1
      celery/canvas.py

+ 1 - 1
celery/canvas.py

@@ -1242,7 +1242,7 @@ class chord(Signature):
         if len(self.tasks) == 1:
         if len(self.tasks) == 1:
             # chord([A], B) can be optimized as A | B
             # chord([A], B) can be optimized as A | B
             # - Issue #3323
             # - Issue #3323
-            return (self.tasks[0].set(task_id=task_id) | body).apply_async(
+            return (self.tasks[0] | body).set(task_id=task_id).apply_async(
                 args, kwargs, **options)
                 args, kwargs, **options)
         # chord([A, B, ...], C)
         # chord([A, B, ...], C)
         return self.run(tasks, body, args, task_id=task_id, **options)
         return self.run(tasks, body, args, task_id=task_id, **options)