​

prefect.deployments.runner

import time
from prefect import flow, serve


@flow
def slow_flow(sleep: int = 60):
    "Sleepy flow - sleeps the provided amount of time (in seconds)."
    time.sleep(sleep)


@flow
def fast_flow():
    "Fastest flow this side of the Mississippi."
    return


if __name__ == "__main__":
    # to_deployment creates RunnerDeployment instances
    slow_deploy = slow_flow.to_deployment(name="sleeper", interval=45)
    fast_deploy = fast_flow.to_deployment(name="fast")

    serve(slow_deploy, fast_deploy)

​

Functions

​

deploy

deploy(*deployments: RunnerDeployment) -> List[UUID]

• *deployments: A list of deployments to deploy.
• work_pool_name: The name of the work pool to use for these deployments. Defaults to the value of PREFECT_DEFAULT_WORK_POOL_NAME.
• image: The name of the Docker image to build, including the registry and repository. Pass a DockerImage instance to customize the Dockerfile used and build arguments.
• build: Whether or not to build a new image for the flow. If False, the provided image will be used as-is and pulled at runtime.
• push: Whether or not to skip pushing the built image to a registry.
• print_next_steps_message: Whether or not to print a message with next steps after deploying the deployments.

• A list of deployment IDs for the created/updated deployments.

from prefect import deploy, flow

@flow(log_prints=True)
def local_flow():
    print("I'm a locally defined flow!")

if __name__ == "__main__":
    deploy(
        local_flow.to_deployment(name="example-deploy-local-flow"),
        flow.from_source(
            source="https://github.com/org/repo.git",
            entrypoint="flows.py:my_flow",
        ).to_deployment(
            name="example-deploy-remote-flow",
        ),
        work_pool_name="my-work-pool",
        image="my-registry/my-image:dev",
    )

​

Classes

​

DeploymentApplyError

​

RunnerDeployment

​

afrom_storage

afrom_storage(cls, storage: RunnerStorage, entrypoint: str, name: str, flow_name: Optional[str] = None, interval: Optional[Union[Iterable[Union[int, float, timedelta]], int, float, timedelta]] = None, cron: Optional[Union[Iterable[str], str]] = None, rrule: Optional[Union[Iterable[str], str]] = None, paused: Optional[bool] = None, schedule: Optional[Schedule] = None, schedules: Optional['FlexibleScheduleList'] = None, concurrency_limit: Optional[Union[int, ConcurrencyLimitConfig, None]] = None, parameters: Optional[dict[str, Any]] = None, triggers: Optional[List[Union[DeploymentTriggerTypes, TriggerTypes]]] = None, description: Optional[str] = None, tags: Optional[List[str]] = None, version: Optional[str] = None, version_type: Optional[VersionType] = None, enforce_parameter_schema: bool = True, work_pool_name: Optional[str] = None, work_queue_name: Optional[str] = None, job_variables: Optional[dict[str, Any]] = None, _sla: Optional[Union[SlaTypes, list[SlaTypes]]] = None) -> 'RunnerDeployment'

• entrypoint: The path to a file containing a flow and the name of the flow function in the format ./path/to/file.py\:flow_func_name.
• name: A name for the deployment
• flow_name: The name of the flow to deploy
• storage: A storage object to use for retrieving flow code. If not provided, a URL must be provided.
• interval: An interval on which to execute the current flow. Accepts either a number or a timedelta object. If a number is given, it will be interpreted as seconds.
• cron: A cron schedule of when to execute runs of this flow.
• rrule: An rrule schedule of when to execute runs of this flow.
• paused: Whether or not the deployment is paused.
• schedule: A schedule object defining when to execute runs of this deployment. Used to provide additional scheduling options like timezone or parameters.
• schedules: A list of schedule objects defining when to execute runs of this deployment. Used to provide additional scheduling options like timezone or parameters.
• triggers: A list of triggers that should kick of a run of this flow.
• parameters: A dictionary of default parameter values to pass to runs of this flow.
• description: A description for the created deployment. Defaults to the flow’s description if not provided.
• tags: A list of tags to associate with the created deployment for organizational purposes.
• version: A version for the created deployment. Defaults to the flow’s version.
• version_type: The type of version information to use for the deployment. The version type will be inferred if not provided.
• enforce_parameter_schema: Whether or not the Prefect API should enforce the parameter schema for this deployment.
• work_pool_name: The name of the work pool to use for this deployment.
• work_queue_name: The name of the work queue to use for this deployment’s scheduled runs. If not provided the default work queue for the work pool will be used.
• job_variables: Settings used to override the values specified default base job template of the chosen work pool. Refer to the base job template of the chosen work pool for available settings.
• _sla: (Experimental) SLA configuration for the deployment. May be removed or modified at any time. Currently only supported on Prefect Cloud.

​

apply

apply(self, work_pool_name: Optional[str] = None, image: Optional[str] = None, version_info: Optional[VersionInfo] = None) -> UUID

• work_pool_name: The name of the work pool to use for this deployment.
• image: The registry, name, and tag of the Docker image to use for this deployment. Only used when the deployment is deployed to a work pool.
• version_info: The version information to use for the deployment.

​

entrypoint_type

entrypoint_type(self) -> EntrypointType

​

from_entrypoint

from_entrypoint(cls, entrypoint: str, name: str, flow_name: Optional[str] = None, interval: Optional[Union[Iterable[Union[int, float, timedelta]], int, float, timedelta]] = None, cron: Optional[Union[Iterable[str], str]] = None, rrule: Optional[Union[Iterable[str], str]] = None, paused: Optional[bool] = None, schedule: Optional[Schedule] = None, schedules: Optional['FlexibleScheduleList'] = None, concurrency_limit: Optional[Union[int, ConcurrencyLimitConfig, None]] = None, parameters: Optional[dict[str, Any]] = None, triggers: Optional[List[Union[DeploymentTriggerTypes, TriggerTypes]]] = None, description: Optional[str] = None, tags: Optional[List[str]] = None, version: Optional[str] = None, enforce_parameter_schema: bool = True, work_pool_name: Optional[str] = None, work_queue_name: Optional[str] = None, job_variables: Optional[dict[str, Any]] = None, _sla: Optional[Union[SlaTypes, list[SlaTypes]]] = None) -> 'RunnerDeployment'

• entrypoint: The path to a file containing a flow and the name of the flow function in the format ./path/to/file.py\:flow_func_name.
• name: A name for the deployment
• flow_name: The name of the flow to deploy
• interval: An interval on which to execute the current flow. Accepts either a number or a timedelta object. If a number is given, it will be interpreted as seconds.
• cron: A cron schedule of when to execute runs of this flow.
• rrule: An rrule schedule of when to execute runs of this flow.
• paused: Whether or not to set this deployment as paused.
• schedules: A list of schedule objects defining when to execute runs of this deployment. Used to define multiple schedules or additional scheduling options like timezone.
• triggers: A list of triggers that should kick of a run of this flow.
• parameters: A dictionary of default parameter values to pass to runs of this flow.
• description: A description for the created deployment. Defaults to the flow’s description if not provided.
• tags: A list of tags to associate with the created deployment for organizational purposes.
• version: A version for the created deployment. Defaults to the flow’s version.
• enforce_parameter_schema: Whether or not the Prefect API should enforce the parameter schema for this deployment.
• work_pool_name: The name of the work pool to use for this deployment.
• work_queue_name: The name of the work queue to use for this deployment’s scheduled runs. If not provided the default work queue for the work pool will be used.
• job_variables: Settings used to override the values specified default base job template of the chosen work pool. Refer to the base job template of the chosen work pool for available settings.
• _sla: (Experimental) SLA configuration for the deployment. May be removed or modified at any time. Currently only supported on Prefect Cloud.

​

from_flow

from_flow(cls, flow: 'Flow[..., Any]', name: str, interval: Optional[Union[Iterable[Union[int, float, timedelta]], int, float, timedelta]] = None, cron: Optional[Union[Iterable[str], str]] = None, rrule: Optional[Union[Iterable[str], str]] = None, paused: Optional[bool] = None, schedule: Optional[Schedule] = None, schedules: Optional['FlexibleScheduleList'] = None, concurrency_limit: Optional[Union[int, ConcurrencyLimitConfig, None]] = None, parameters: Optional[dict[str, Any]] = None, triggers: Optional[List[Union[DeploymentTriggerTypes, TriggerTypes]]] = None, description: Optional[str] = None, tags: Optional[List[str]] = None, version: Optional[str] = None, version_type: Optional[VersionType] = None, enforce_parameter_schema: bool = True, work_pool_name: Optional[str] = None, work_queue_name: Optional[str] = None, job_variables: Optional[dict[str, Any]] = None, entrypoint_type: EntrypointType = EntrypointType.FILE_PATH, _sla: Optional[Union[SlaTypes, list[SlaTypes]]] = None) -> 'RunnerDeployment'

• flow: A flow function to deploy
• name: A name for the deployment
• interval: An interval on which to execute the current flow. Accepts either a number or a timedelta object. If a number is given, it will be interpreted as seconds.
• cron: A cron schedule of when to execute runs of this flow.
• rrule: An rrule schedule of when to execute runs of this flow.
• paused: Whether or not to set this deployment as paused.
• schedule: A schedule object defining when to execute runs of this deployment. Used to provide additional scheduling options like timezone or parameters.
• schedules: A list of schedule objects defining when to execute runs of this deployment. Used to define multiple schedules or additional scheduling options like timezone.
• concurrency_limit: The maximum number of concurrent runs this deployment will allow.
• triggers: A list of triggers that should kick of a run of this flow.
• parameters: A dictionary of default parameter values to pass to runs of this flow.
• description: A description for the created deployment. Defaults to the flow’s description if not provided.
• tags: A list of tags to associate with the created deployment for organizational purposes.
• version: A version for the created deployment. Defaults to the flow’s version.
• version_type: The type of version information to use for the deployment.
• enforce_parameter_schema: Whether or not the Prefect API should enforce the parameter schema for this deployment.
• work_pool_name: The name of the work pool to use for this deployment.
• work_queue_name: The name of the work queue to use for this deployment’s scheduled runs. If not provided the default work queue for the work pool will be used.
• job_variables: Settings used to override the values specified default base job template of the chosen work pool. Refer to the base job template of the chosen work pool for available settings.
• _sla: (Experimental) SLA configuration for the deployment. May be removed or modified at any time. Currently only supported on Prefect Cloud.

​

from_storage

from_storage(cls, storage: RunnerStorage, entrypoint: str, name: str, flow_name: Optional[str] = None, interval: Optional[Union[Iterable[Union[int, float, timedelta]], int, float, timedelta]] = None, cron: Optional[Union[Iterable[str], str]] = None, rrule: Optional[Union[Iterable[str], str]] = None, paused: Optional[bool] = None, schedule: Optional[Schedule] = None, schedules: Optional['FlexibleScheduleList'] = None, concurrency_limit: Optional[Union[int, ConcurrencyLimitConfig, None]] = None, parameters: Optional[dict[str, Any]] = None, triggers: Optional[List[Union[DeploymentTriggerTypes, TriggerTypes]]] = None, description: Optional[str] = None, tags: Optional[List[str]] = None, version: Optional[str] = None, version_type: Optional[VersionType] = None, enforce_parameter_schema: bool = True, work_pool_name: Optional[str] = None, work_queue_name: Optional[str] = None, job_variables: Optional[dict[str, Any]] = None, _sla: Optional[Union[SlaTypes, list[SlaTypes]]] = None) -> 'RunnerDeployment'

• entrypoint: The path to a file containing a flow and the name of the flow function in the format ./path/to/file.py\:flow_func_name.
• name: A name for the deployment
• flow_name: The name of the flow to deploy
• storage: A storage object to use for retrieving flow code. If not provided, a URL must be provided.
• interval: An interval on which to execute the current flow. Accepts either a number or a timedelta object. If a number is given, it will be interpreted as seconds.
• cron: A cron schedule of when to execute runs of this flow.
• rrule: An rrule schedule of when to execute runs of this flow.
• paused: Whether or not the deployment is paused.
• schedule: A schedule object defining when to execute runs of this deployment. Used to provide additional scheduling options like timezone or parameters.
• schedules: A list of schedule objects defining when to execute runs of this deployment. Used to provide additional scheduling options like timezone or parameters.
• triggers: A list of triggers that should kick of a run of this flow.
• parameters: A dictionary of default parameter values to pass to runs of this flow.
• description: A description for the created deployment. Defaults to the flow’s description if not provided.
• tags: A list of tags to associate with the created deployment for organizational purposes.
• version: A version for the created deployment. Defaults to the flow’s version.
• version_type: The type of version information to use for the deployment. The version type will be inferred if not provided.
• enforce_parameter_schema: Whether or not the Prefect API should enforce the parameter schema for this deployment.
• work_pool_name: The name of the work pool to use for this deployment.
• work_queue_name: The name of the work queue to use for this deployment’s scheduled runs. If not provided the default work queue for the work pool will be used.
• job_variables: Settings used to override the values specified default base job template of the chosen work pool. Refer to the base job template of the chosen work pool for available settings.
• _sla: (Experimental) SLA configuration for the deployment. May be removed or modified at any time. Currently only supported on Prefect Cloud.

​

full_name

full_name(self) -> str

​

reconcile_paused

reconcile_paused(cls, values: dict[str, Any]) -> dict[str, Any]

​

reconcile_schedules

reconcile_schedules(cls, values: dict[str, Any]) -> dict[str, Any]

​

validate_automation_names

validate_automation_names(self)

​

validate_deployment_parameters

validate_deployment_parameters(self) -> Self

​

validate_name

validate_name(cls, value: str) -> str