celery run

celery_examle.py

comments = []
comment_tasks = []

# loop and add part one all tasks
for comment in comments:
    comment_info = {
        'id': comment.id,
        'message': comment.message
    }
    comment_tasks.append(do_analyze.si(task_info, comment_info))

# 链式 Part one and Part two
chain(
    group(*comment_tasks),
    do_finish_task.si(task_id)
)()