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