- 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))
|