app.celery_app

Celery application configuration for the FLOW Preprocessing Service.

Functions

before_task_publish_handler([headers, body])	Fire before task is sent to the broker.
task_failure_handler([task_id, exception, ...])	Fire when a task fails terminally.
task_postrun_handler([task_id, state, ...])	Fire when task succeeds.
task_prerun_handler([task_id])	Fire when task begins executing.
task_retry_handler([task_id, reason])	Fire when task fails and it retries.