celery chord example.py

celery chord example.py

from celery import Celery 
from celery import chord

a = Celery()

a.conf.update (
    CELERY_BROKER_URL = 'amqp://',
    CELERY_RESULT_BACKEND = 'amqp',
    CELERY_TASK_SERIALIZER = 'json',
    CELERY_ACCEPT_CONTENT = ['json'],
    CELERY_RESULT_SERIALIZER = 'json',
    CELERY_ENABLE_UTC = True,
)


@a.task(ignore_result = False)
def add(x, y):
    return x + y

@a.task(ignore_result = False)
def tsum(numbers):
    return sum(numbers)