Logs

Celery tasks & scheduling

1 min read

🧵 Core logic

Workflow tasks are implemented via BaseWorkflowTask (apps/workflows/tasks/base.py) and wrappers in tasks/*.py.

✅ Active tasks

  • start_subscription_drop_monitoring_workflow_task
  • start_unsubscription_spike_monitoring_workflow_task
  • start_campaign_runner_workflow_task (used in Campaign Planner)

⏰ Schedule (Celery Beat)

Defined in conf/settings/common.py:

  • subscription_drop_monitoring — daily at 05:00 UTC
  • unsubscription_spike_monitoring — daily at 05:00 UTC

🚫 Disabled tasks

Present in code but commented out:

  • reactivating_unsubscribed_users
  • firebase_reports

To enable:

  1. uncomment the task in tasks/__init__.py
  2. add/uncomment the schedule in CELERY_BEAT_SCHEDULE

0 items under this folder.