mygpo/cel.py

   1 from __future__ import absolute_import
   2
   3 from django.conf import settings
   4
   5 from celery import Celery
   6
   7 import sys
   8 import os
   9
  10
  11 celery = Celery('mygpo.celery',
  12                 broker=settings.BROKER_URL,
  13                 backend=settings.BACKEND_URL,
  14                 include=[
  15                     'mygpo.core.tasks',
  16                     'mygpo.data.tasks',
  17                     'mygpo.admin.tasks',
  18                     'mygpo.directory.tasks',
  19                 ])
  20
  21 celery.conf.update(
  22     **settings.CELERY_CONF
  23 )
  24
  25 if __name__ == '__main__':
  26     celery.start()