| ####### SAMPLE celery.py | |
| from celery import Celery | |
| def get_application(): | |
| _initialize() | |
| application = Celery(...) | |
| application.conf.update(...) | |
| return application | |
| ####### SAMPLE worker.py | |
| from celery import task | |
| @task(serializer="json") | |
| def doathing(arg1, arg2): | |
| print "I'm doing a thing" |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment