RSVP for your your local TensorFlow Everywhere event today!

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_jobs_manager An optional ServiceJobManager instance if service jobs are supported.

status_lib.StatusNotOkError If error generating tasks.