Source

django-celery-about / source / canvas.rst

Full commit

Canvas:サブタスクでワークフロー

subtask

taskの内容を決めたもの

>>> from app.tasks import *
>>> h1 = hello.subtask(args=["I'am  a cat"])
>>> h1
app.tasks.hello("I'am  a cat")
>>> type(h1)
<class 'celery.canvas.Signature'>
>>> str(h1)
'app.tasks.hello("I\'am  a cat")'

呼び出しを後で行う

>>> h1.apply()
<EagerResult: a701c9a4-11fc-42f3-aae8-341f7098a9c5

>>>> h1.apply_async()
<AsyncResult: b1cc1a33-4d82-4684-937b-0a836ce6bca0>

Chords (コールバック付きGroups)

  • header group + body group