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.users.tasks',
  17                     'mygpo.data.tasks',
  18                     'mygpo.admin.tasks',
  19                     'mygpo.directory.tasks',
  20                 ])
  21
  22 celery.conf.update(
  23     **settings.CELERY_CONF
  24 )
  25
  26 if __name__ == '__main__':
  27     celery.start()