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

hilmar8 · Dec 2, 2016 · fe2c47d · fe2c47d
1 parent b535e3a
commit fe2c47d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/celery/canvas.py b/celery/canvas.py
@@ -1242,7 +1242,7 @@ def apply_async(self, args=(), kwargs={}, task_id=None,
         if len(self.tasks) == 1:
             # chord([A], B) can be optimized as A | B
             # - 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)
         # chord([A, B, ...], C)
         return self.run(tasks, body, args, task_id=task_id, **options)