GitHub

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_job_manager: tfx.orchestration.experimental.core.service_jobs.ServiceJobManager
) -> 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_job_manager`	A `ServiceJobManager` instance for handling service jobs.

Raises
`status_lib.StatusNotOkError`	If error generating tasks.

Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License, and code samples are licensed under the Apache 2.0 License. For details, see the Google Developers Site Policies. Java is a registered trademark of Oracle and/or its affiliates.

Last updated 2021-04-13 UTC.

tfx.orchestration.experimental.core.pipeline_ops.orchestrate

Args

Raises