backend/global/celery_config.py
from __future__ import absolute_importimport osfrom celery import Celery os.environ.setdefault("DJANGO_SETTINGS_MODULE", "global.settings.prod") app = Celery('synapse')app.config_from_object('django.conf:settings', namespace='CELERY')app.conf.task_acks_late = True app.autodiscover_tasks() @app.task(bind=True)def debug_task(self): print('Request: {0!r}'.format(self.request))