Merge pull request #692 from adityacp/merge_monitor_regrade

Merge monitor regrade

1 files changed, 25 insertions, 0 deletions

diff --git a/online_test/celery.py b/online_test/celery.py
new file mode 100644
index 0000000..6868b89
--- /dev/null
+++ b/online_test/celery.py
@@ -0,0 +1,25 @@
+from __future__ import absolute_import, unicode_literals
+
+import os
+from django.conf import settings
+from celery import Celery
+
+# set the default Django settings module for the 'celery' program.
+os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'online_test.settings')
+
+app = Celery('online_test')
+
+# Using a string here means the worker doesn't have to serialize
+# the configuration object to child processes.
+# - namespace='CELERY' means all celery-related configuration keys
+#   should have a `CELERY_` prefix.
+app.config_from_object('django.conf:settings', namespace='CELERY')
+
+# Load task modules from all registered Django app configs.
+app.autodiscover_tasks(lambda: settings.INSTALLED_APPS)
+
+@app.task(name='celery.ping')
+def ping():
+    # type: () -> str
+    """Simple task that just returns 'pong'."""
+    return 'pong'