Sfoglia il codice sorgente

Fix issue mentioned in https://github.com/celery/celery/issues/1671

See the comment from @lance-burton on June 20, 2014.

A nested group in an expression such as:
c = (group(add.s(1,1),add.s(2,2))
     | add.s(1)
     | add.s(1)
     | group(mul.s(1),mul.s(2)))
res = c.apply_async().get()

Causes an "AttributeError: 'dict' object has no attribute 'type'".
Aneil Mallavarapu 10 anni fa
parent
commit
05f84b34b1
1 ha cambiato i file con 1 aggiunte e 1 eliminazioni
  1. 1 1
      celery/canvas.py

+ 1 - 1
celery/canvas.py

@@ -602,7 +602,7 @@ def _maybe_group(tasks):
     elif isinstance(tasks, Signature):
         tasks = [tasks]
     else:
-        tasks = regen(tasks)
+        tasks = map(signature, regen(tasks))
     return tasks