tfx.orchestration.experimental.core.pipeline_ops.orchestrate

Performs a single iteration of the orchestration loop.

tfx.orchestration.experimental.core.pipeline_ops.orchestrate(
    mlmd_handle: tfx.orchestration.metadata.Metadata,
    task_queue: tfx.orchestration.experimental.core.task_queue.TaskQueue,
    service_jobs_manager: Optional[tfx.orchestration.experimental.core.service_jobs.ServiceJobManager] = None
) -> None

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

Args
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.

Raises
status_lib.StatusNotOkError	If error generating tasks.