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