from tfx.orchestration import pipeline
from tfx.orchestration.local.local_dag_runner import LocalDagRunner

# Define the pipeline
pipeline = pipeline.Pipeline(
    pipeline_name='iris_pipeline',
    pipeline_root='/content/iris_pipeline',
    components=[example_gen, statistics_gen, schema_gen, example_validator, transform, trainer, evaluator, pusher],
    enable_cache=True,
    metadata_connection_config=None
)

# Run the pipeline
LocalDagRunner().run(pipeline)

        __
        __