From 94586aa5b189328c0efd5cf3817f9c1164330a4b Mon Sep 17 00:00:00 2001 From: Maxime Bloch Date: Wed, 22 Jul 2020 04:02:38 +0200 Subject: [PATCH] Add celery base --- KeRS/celery.py | 27 +++++++++++++++++++++++++++ 1 file changed, 27 insertions(+) create mode 100644 KeRS/celery.py diff --git a/KeRS/celery.py b/KeRS/celery.py new file mode 100644 index 0000000..87043b6 --- /dev/null +++ b/KeRS/celery.py @@ -0,0 +1,27 @@ +from __future__ import absolute_import, unicode_literals + +import os + +from celery import Celery + +# set the default Django settings module for the 'celery' program. +os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'KeRS.settings') + +app = Celery('KeRS', + broker='redis://localhost:6379/0', + backend='redis://localhost:6379/1' + ) + +# 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() + + +@app.task(bind=True) +def debug_task(self): + print('Request: {0!r}'.format(self.request))