Преглед на файлове

Also pass partial args for frozen chain

Ask Solem преди 10 години
родител
ревизия
bef6847b67
променени са 1 файла, в които са добавени 2 реда и са изтрити 0 реда
  1. 2 0
      celery/canvas.py

+ 2 - 0
celery/canvas.py

@@ -432,6 +432,8 @@ class chain(Signature):
             # first task gets partial args from chain
             if clone:
                 task = task.clone(args) if not i else task.clone()
+            elif not i:
+                task.args = tuple(args) + tuple(task.args)
 
             if isinstance(task, chain):
                 # splice the chain