dwa_1067_add_chord.py

from celery import Celery
from celery import chord
import time

app = Celery(name="tasks",
			 broker="redis://localhost:6379/0",
			 backend="db+sqlite:///db+sqlite3"
			)
@app.task
def sum_2_num(param1, param2):
    return param2+param1

@app.task
def total_sum(numbers):
    return sum(numbers)

callback = total_sum.s()
header = [ sum_2_num.s(1,2), sum_2_num.s(3,4), sum_2_num.s(5,45) ]
result = chord(header)(callback)
result.get()