celery.py 294 B

123456789101112
  1. from __future__ import absolute_import
  2. from celery import Celery
  3. celery = Celery(broker='amqp://',
  4. backend='amqp://',
  5. include=['proj.tasks'])
  6. # Optional configuration, see the application user guide.
  7. celery.conf.update(
  8. CELERY_TASK_RESULT_EXPIRES=3600,
  9. )