celery/examples/app/myapp.py

"""myapp.py

Usage:

   (window1)$ python myapp.py -l info

   (window2)$ python
   >>> from myapp import add
   >>> add.delay(16, 16).get()
   32

"""
from celery import Celery


celery = Celery("myapp")
celery.conf.update(BROKER_HOST="localhost")


@celery.task(accept_magic_kwargs=False)
def add(x, y, **kwargs):
    print("add id: %r %r %r" % (add.request.id, add.request.args,
        add.request.kwargs))
    print("kwargs: %r" % (kwargs, ))
    return x + y

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