Join the SIG TFX-Addons community and help make TFX even better!

tfx.orchestration.experimental.core.pipeline_ops.orchestrate

Performs a single iteration of the orchestration loop.

Embodies the core functionality of the main orchestration loop that scans MLMD pipeline execution states, generates and enqueues the tasks to be performed.

mlmd_handle A handle to the MLMD db.
task_queue A TaskQueue instance into which any tasks will be enqueued.
service_job_manager A ServiceJobManager instance for handling service jobs.

status_lib.StatusNotOkError If error generating tasks.