celery.py 279 B

1234567891011
  1. from __future__ import absolute_import
  2. from celery import Celery
  3. celery = Celery("proj", broker="amqp://", backend="amqp")
  4. celery.conf.CELERY_IMPORTS = ("proj.tasks", )
  5. if __name__ == "__main__":
  6. from billiard import freeze_support
  7. freeze_support()
  8. celery.start()