celery/examples/tutorial/tasks.py

from __future__ import absolute_import

from celery import Celery

celery = Celery("tasks", broker="amqp://")

@celery.task()
def add(x, y):
    return x + y

if __name__ == "__main__":
    celery.start()