app.celery_app

Celery application configuration for the FLOW Inference Service.

Functions

before_task_publish_handler([headers, body])	Fire before task is sent to the broker.
task_failure_handler([task_id, exception, ...])	Fire when task fails permanently.
task_postrun_handler([task_id, state, retval])	Fire when task finishes successfully.
task_prerun_handler([task_id])	Fire when task begins executing.
task_retry_handler([request, reason, einfo, ...])	Fire when task retries.