Module core.backends.orchestrator.local.zenml_local_orchestrator

Classes

ZenMLLocalDagRunner(config: Union[tfx.orchestration.config.pipeline_config.PipelineConfig, NoneType] = None) : This is the almost the same as the super class from tfx: tfx.orchestration.local.local_dag_runner.LocalDagRunner with the exception being that the pipeline_run is not overridden. Full credit to Google LLC for the original source code found at: https://github.com/tensorflow/tfx/blob/master/tfx/orchestration/local/

Initializes local TFX orchestrator.

Args:
  config: Optional pipeline config for customizing the launching of each
    component. Defaults to pipeline config that supports
    InProcessComponentLauncher and DockerComponentLauncher.

### Ancestors (in MRO)

* tfx.orchestration.local.local_dag_runner.LocalDagRunner
* tfx.orchestration.tfx_runner.TfxRunner

### Methods

`run(self, tfx_pipeline: tfx.orchestration.pipeline.Pipeline) ‑> NoneType`
:   Runs given logical pipeline locally.
    
    Args:
      tfx_pipeline: Logical pipeline containing pipeline args and components.