prefect.server.orchestration.dependencies

Injected orchestration dependencies

Functions

provide_task_policy

provide_task_policy() -> type[TaskRunOrchestrationPolicy]

provide_flow_policy

provide_flow_policy() -> type[FlowRunOrchestrationPolicy]

provide_task_orchestration_parameters

provide_task_orchestration_parameters() -> dict[str, Any]

provide_flow_orchestration_parameters

provide_flow_orchestration_parameters() -> dict[str, Any]

temporary_task_policy

temporary_task_policy(tmp_task_policy: type[TaskRunOrchestrationPolicy])

temporary_flow_policy

temporary_flow_policy(tmp_flow_policy: type[FlowRunOrchestrationPolicy])

temporary_task_orchestration_parameters

temporary_task_orchestration_parameters(tmp_orchestration_parameters: dict[str, Any])

temporary_flow_orchestration_parameters

temporary_flow_orchestration_parameters(tmp_orchestration_parameters: dict[str, Any])

Classes

OrchestrationDependencies