celery.py 301 B

12345678910111213
  1. import os
  2. from celery import Celery
  3. os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'emus.settings')
  4. app = Celery('emus')
  5. app.config_from_object('django.conf:settings', namespace='CELERY')
  6. app.autodiscover_tasks()
  7. @app.task(bind=True)
  8. def debug_task(self):
  9. print(f'Request: {self.request!r}')