dwa_1068_callbacks.py

from celery import signature
from celery import Celery 
import json

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

@app.task
def division(param1, param2):
    return param2/param1

@app.task
def success_handler(result):
	print(task_id)
	return task_id

@app.task
def error_handler(task_id):
	print(task_id)
	return task_id

sum_task = signature(
		'callbacks.division',
		args=(0, 1),
		link=success_handler.s(),
		link_error=error_handler.s()
	)
sum_task.apply_async()