| 1234567891011121314 |
- from celery import Celery
- import os
- os.environ.setdefault("DJANGO_SETTINGS_MODULE", "preports.settings")
- app = Celery('preports')
- app.config_from_object("django.conf:settings", namespace="CELERY")
- app.autodiscover_tasks()
- @app.on_after_finalize.connect
- def setup_periodical_tasks(sender, **kwargs):
- from api.tasks import send_due_reports
- sender.add_periodic_task(10.0, send_due_reports.s(),
- name="Send due Programmed Reports.")
|
