Module: tfx.orchestration.experimental.core.pipeline_ops

Pipeline-level operations.

Functions

initiate_node_start(...): Initiates a node start operation for a node in an async pipeline.

initiate_pipeline_start(...): Initiates a pipeline start operation.

orchestrate(...): Performs a single iteration of the orchestration loop.

remove_pipeline_property(...): Removes a property from the pipeline execution.

save_pipeline_property(...): Saves a property to the pipeline execution.

stop_node(...): Stops a node in an async pipeline.

stop_pipeline(...): Stops a pipeline.

Other Members
DEFAULT_WAIT_FOR_INACTIVATION_TIMEOUT_SECS	120.0