dwa_1067_add_chain.py

from celery import Celery
from celery import chain
import time

app = Celery(name="tasks",
			 broker="redis://localhost:6379/0",
			 backend="db+sqlite:///db+sqlite3"
			)

@app.task
def add(num_1, num_2):
	time.sleep(15)
	return num_1 + num_2

 res = chain(add.s(1, 2), add.s(3), add.s(9)).apply_async()

 # OR 
 #  res2 = (add.s(1, 2) | add.s(3)).apply_async()

if res.ready():
	print(res.get())               # add.s(1, 2), add.s(3), add.s(9)
	print(res.parent.get())        # add.s(1, 2), add.s(3)
	print(res.parent.parent.get()) # add.s(1, 2)