celery/examples/tutorial/tasks.py

from __future__ import absolute_import

from celery import Celery

app = Celery('tasks', broker='amqp://')


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

if __name__ == '__main__':
    app.start()