services
cancellation_cleanup
The CancellationCleanup service. Responsible for cancelling tasks and subflows that haven’t finished.
Was this page helpful?
Documentation Index
Fetch the complete documentation index at: /llms.txt
Use this file to discover all available pages before exploring further.
prefect.server.services.cancellation_cleanupcancelling_timeout_check_key cancelling_timeout_check_key(flow_run_id: UUID) -> str
schedule_cancelling_timeout_check schedule_cancelling_timeout_check() -> None
maybe_schedule_cancelling_timeout_check_for_state maybe_schedule_cancelling_timeout_check_for_state() -> None
cancel_child_task_runs cancel_child_task_runs(flow_run_id: Annotated[UUID, Logged]) -> None
cancel_subflow_run cancel_subflow_run(subflow_run_id: Annotated[UUID, Logged]) -> None
handle_cancelling_timeout handle_cancelling_timeout(flow_run_id: Annotated[UUID, Logged], flow_run_state_id: Annotated[UUID, Logged], timeout_cancelled_state_id: Annotated[UUID, Logged]) -> CleanupQueueMessage | None
ensure_cancelling_timeout_checks ensure_cancelling_timeout_checks(docket: Docket = CurrentDocket(), db: PrefectDBInterface = Depends(provide_database_interface), perpetual: Perpetual = Perpetual(automatic=True, every=datetime.timedelta(seconds=get_current_settings().server.services.cancellation_cleanup.loop_seconds))) -> None
monitor_cancelled_flow_runs monitor_cancelled_flow_runs(docket: Docket = CurrentDocket(), db: PrefectDBInterface = Depends(provide_database_interface), perpetual: Perpetual = Perpetual(automatic=True, every=datetime.timedelta(seconds=get_current_settings().server.services.cancellation_cleanup.loop_seconds))) -> None
monitor_subflow_runs monitor_subflow_runs(docket: Docket = CurrentDocket(), db: PrefectDBInterface = Depends(provide_database_interface), perpetual: Perpetual = Perpetual(automatic=True, every=datetime.timedelta(seconds=get_current_settings().server.services.cancellation_cleanup.loop_seconds))) -> None
Was this page helpful?