- from __future__ import absolute_import
 
- from celery import Celery
 
- from django.conf import settings
 
- celery = Celery('tasks', broker='amqp://localhost')
 
- celery.config_from_object(settings)
 
- celery.autodiscover_tasks(settings.INSTALLED_APPS)
 
- @celery.task
 
- def debug_task():
 
-     print(repr(debug_task.request))
 
 
  |