@@ -166,15 +166,18 @@ class AsyncResult(ResultBase):
.. code-block:: python
- @task()
+ from celery import group
+ from proj.celery import app
+
+ @app.task
def A(how_many):
- return group(B.s(i) for i in range(how_many))
+ return group(B.s(i) for i in range(how_many))()
def B(i):
return pow2.delay(i)
def pow2(i):
return i ** 2