Celery configuration

4 files changed, 35 insertions, 2 deletions

diff --git a/example_project/__init__.py b/example_project/__init__.py.base.sample
index c6adb7559..c6adb7559 100644
--- a/example_project/__init__.py
+++ b/example_project/__init__.py.base.sample
diff --git a/example_project/__init__.py.celery.sample b/example_project/__init__.py.celery.sample
new file mode 100644
index 000000000..ebae6a3c3
--- /dev/null
+++ b/example_project/__init__.py.celery.sample
@@ -0,0 +1,15 @@
+# force the retranslation of generated strings and external module
+from django.utils.translation import ugettext_lazy as _
+
+from .celery import app as celery_app
+
+__all__ = ('celery_app',)
+
+_(u"username")
+_(u"email address")
+_(u"warehouse")
+_(u"New warehouse")
+_(u"warehouse")
+_(u"New organization")
+_(u"New person")
+_(u"New author")
diff --git a/example_project/celery.py.sample b/example_project/celery.py.sample
new file mode 100644
index 000000000..3aed98038
--- /dev/null
+++ b/example_project/celery.py.sample
@@ -0,0 +1,18 @@
+import os
+from celery import Celery
+
+# change example_project with your project name
+project_name = "example_project"
+
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', project_name + '.settings')
+
+app = Celery(project_name)
+
+app.config_from_object('django.conf:settings', namespace='CELERY')
+app.autodiscover_tasks()
+
+
+@app.task(bind=True)
+def debug_task(self):
+    print('Request: {0!r}'.format(self.request))
\ No newline at end of file
diff --git a/example_project/settings.py b/example_project/settings.py
index 8a7343212..09590f807 100644
--- a/example_project/settings.py
+++ b/example_project/settings.py
@@ -273,7 +273,7 @@ DOT_BINARY = ""
 TEST_RUNNER = 'ishtar_common.tests.ManagedModelTestRunner'
 
 try:
-    from local_settings import *
+    from .local_settings import *
 except ImportError as e:
     print('Unable to load local_settings.py:', e)
 
@@ -316,7 +316,7 @@ if DEBUG:
             LOGGING['loggers'][logger]['handlers'] += ['console']
 
 if USE_BACKGROUND_TASK:
-    INSTALLED_APPS.append('background_task')
+    CELERY_BROKER_URL = 'amqp://localhost'
 
 if DJANGO_EXTENSIONS:
     INSTALLED_APPS.append('django_extensions')