Celery Canvas Workflows:

In Simple Words:

• chain: Executes tasks sequentially (task1 | task2).
• group: Executes tasks in parallel.
• chord: Executes a group in parallel, then calls a callback when all finish.

from celery import chain, group

# Chain: step1 -> step2 -> step3
workflow = chain(
    fetch_data.s(10),
    transform_data.s(),
    save_to_db.s()
)
workflow.apply_async()