Path	Lines of Code
tfx/orchestration/airflow/__init__.py	1
tfx/orchestration/airflow/airflow_component.py	58
tfx/orchestration/airflow/airflow_dag_runner.py	78
tfx/orchestration/airflow/airflow_runner.py	6
tfx/orchestration/beam/__init__.py	1
tfx/orchestration/beam/beam_dag_runner.py	187
tfx/orchestration/beam/legacy/__init__.py	1
tfx/orchestration/beam/legacy/beam_dag_runner.py	88
tfx/orchestration/config/__init__.py	1
tfx/orchestration/config/base_component_config.py	3
tfx/orchestration/config/config_utils.py	21
tfx/orchestration/config/docker_component_config.py	34
tfx/orchestration/config/kubernetes_component_config.py	9
tfx/orchestration/config/pipeline_config.py	30
tfx/orchestration/data_types.py	89
tfx/orchestration/data_types_utils.py	192
tfx/orchestration/experimental/__init__.py	1
tfx/orchestration/experimental/core/__init__.py	1
tfx/orchestration/experimental/core/async_pipeline_task_gen.py	214
tfx/orchestration/experimental/core/constants.py	5
tfx/orchestration/experimental/core/env.py	25
tfx/orchestration/experimental/core/mlmd_state.py	77
tfx/orchestration/experimental/core/orchestration_options.py	5
tfx/orchestration/experimental/core/pipeline_ops.py	527
tfx/orchestration/experimental/core/pipeline_state.py	557
tfx/orchestration/experimental/core/sample_mlmd_creator.py	101
tfx/orchestration/experimental/core/service_jobs.py	75
tfx/orchestration/experimental/core/sync_pipeline_task_gen.py	321
tfx/orchestration/experimental/core/task.py	90
tfx/orchestration/experimental/core/task_gen.py	8
tfx/orchestration/experimental/core/task_gen_utils.py	160
tfx/orchestration/experimental/core/task_manager.py	244
tfx/orchestration/experimental/core/task_queue.py	47
tfx/orchestration/experimental/core/task_scheduler.py	91
tfx/orchestration/experimental/core/task_schedulers/__init__.py	1
tfx/orchestration/experimental/core/task_schedulers/importer_task_scheduler.py	33
tfx/orchestration/experimental/core/task_schedulers/manual_task_scheduler.py	60
tfx/orchestration/experimental/core/task_schedulers/noop_task_scheduler.py	23
tfx/orchestration/experimental/core/task_schedulers/resolver_task_scheduler.py	13
tfx/orchestration/experimental/core/testing/__init__.py	1
tfx/orchestration/experimental/interactive/__init__.py	1
tfx/orchestration/experimental/interactive/execution_result.py	18
tfx/orchestration/experimental/interactive/export_templates/__init__.py	1
tfx/orchestration/experimental/interactive/interactive_context.py	153
tfx/orchestration/experimental/interactive/notebook_extensions/__init__.py	1
tfx/orchestration/experimental/interactive/notebook_extensions/skip.py	11
tfx/orchestration/experimental/interactive/notebook_formatters.py	149
tfx/orchestration/experimental/interactive/standard_visualizations.py	61
tfx/orchestration/experimental/interactive/visualizations.py	26
tfx/orchestration/experimental/kubernetes/__init__.py	1
tfx/orchestration/experimental/kubernetes/container_entrypoint.py	60
tfx/orchestration/experimental/kubernetes/kubernetes_dag_runner.py	151
tfx/orchestration/experimental/kubernetes/kubernetes_remote_runner.py	160
tfx/orchestration/experimental/kubernetes/node_wrapper.py	26
tfx/orchestration/experimental/kubernetes/orchestrator_container_entrypoint.py	19
tfx/orchestration/experimental/kubernetes/yaml/jupyter.yaml	19
tfx/orchestration/experimental/kubernetes/yaml/kustomization.yaml	6
tfx/orchestration/experimental/kubernetes/yaml/mysql-pv.yaml	10
tfx/orchestration/experimental/kubernetes/yaml/mysql.yaml	53
tfx/orchestration/experimental/kubernetes/yaml/roles.yaml	15
tfx/orchestration/experimental/kubernetes/yaml/service-account.yaml	11
tfx/orchestration/kubeflow/__init__.py	1
tfx/orchestration/kubeflow/base_component.py	81
tfx/orchestration/kubeflow/container_entrypoint.py	275
tfx/orchestration/kubeflow/kubeflow_dag_runner.py	195
tfx/orchestration/kubeflow/proto/kubeflow.proto	46
tfx/orchestration/kubeflow/runner.py	10
tfx/orchestration/kubeflow/utils.py	20
tfx/orchestration/kubeflow/v2/__init__.py	1
tfx/orchestration/kubeflow/v2/artifact_types/Artifact.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Boolean.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Dataset.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/ExampleAnomalies.yaml	9
tfx/orchestration/kubeflow/v2/artifact_types/ExampleStatistics.yaml	9
tfx/orchestration/kubeflow/v2/artifact_types/Examples.yaml	12
tfx/orchestration/kubeflow/v2/artifact_types/File.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Float.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/HyperParameters.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/InferenceResult.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/InfraBlessing.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Integer.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Metrics.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Model.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/ModelBlessing.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/ModelEvaluation.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/ModelRun.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/PushedModel.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Schema.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/Statistics.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/String.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/TransformCache.yaml	2
tfx/orchestration/kubeflow/v2/artifact_types/TransformGraph.yaml	2
tfx/orchestration/kubeflow/v2/compiler_utils.py	276
tfx/orchestration/kubeflow/v2/components/__init__.py	1
tfx/orchestration/kubeflow/v2/components/experimental/__init__.py	3
tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_component.py	92
tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_executor.py	35
tfx/orchestration/kubeflow/v2/container/__init__.py	1
tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils.py	173
tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor.py	86
tfx/orchestration/kubeflow/v2/decorators.py	7
tfx/orchestration/kubeflow/v2/e2e_tests/base_test_case.py	84
tfx/orchestration/kubeflow/v2/file_based_example_gen/__init__.py	1
tfx/orchestration/kubeflow/v2/file_based_example_gen/driver.py	94
tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner.py	89
tfx/orchestration/kubeflow/v2/parameter_utils.py	18
tfx/orchestration/kubeflow/v2/pipeline_builder.py	105
tfx/orchestration/kubeflow/v2/step_builder.py	463
tfx/orchestration/kubeflow/v2/vertex_client_utils.py	24
tfx/orchestration/launcher/__init__.py	1
tfx/orchestration/launcher/base_component_launcher.py	120
tfx/orchestration/launcher/container_common.py	91
tfx/orchestration/launcher/docker_component_launcher.py	53
tfx/orchestration/launcher/in_process_component_launcher.py	38
tfx/orchestration/launcher/kubernetes_component_launcher.py	142
tfx/orchestration/local/__init__.py	1
tfx/orchestration/local/legacy/__init__.py	1
tfx/orchestration/local/legacy/local_dag_runner.py	49
tfx/orchestration/local/local_dag_runner.py	67
tfx/orchestration/local/runner_utils.py	88
tfx/orchestration/metadata.py	715
tfx/orchestration/metadata_test_utils.py	527
tfx/orchestration/pipeline.py	111
tfx/orchestration/portable/__init__.py	1
tfx/orchestration/portable/base_driver.py	12
tfx/orchestration/portable/base_driver_operator.py	20
tfx/orchestration/portable/base_executor_operator.py	31
tfx/orchestration/portable/beam_executor_operator.py	47
tfx/orchestration/portable/cache_utils.py	92
tfx/orchestration/portable/data_types.py	57
tfx/orchestration/portable/docker_executor_operator.py	88
tfx/orchestration/portable/execution_publish_utils.py	131
tfx/orchestration/portable/execution_watcher.py	70
tfx/orchestration/portable/importer_node_handler.py	78
tfx/orchestration/portable/input_resolution/exceptions.py	14
tfx/orchestration/portable/input_resolution/processor.py	79
tfx/orchestration/portable/inputs_utils.py	177
tfx/orchestration/portable/kubernetes_executor_operator.py	141
tfx/orchestration/portable/launcher.py	414
tfx/orchestration/portable/mlmd/__init__.py	1
tfx/orchestration/portable/mlmd/common_utils.py	41
tfx/orchestration/portable/mlmd/context_lib.py	85
tfx/orchestration/portable/mlmd/event_lib.py	47
tfx/orchestration/portable/mlmd/execution_lib.py	181
tfx/orchestration/portable/outputs_utils.py	191
tfx/orchestration/portable/partial_run_utils.py	396
tfx/orchestration/portable/python_driver_operator.py	25
tfx/orchestration/portable/python_executor_operator.py	65
tfx/orchestration/portable/resolver_node_handler.py	96
tfx/orchestration/portable/runtime_parameter_utils.py	97
tfx/orchestration/portable/system_node_handler.py	14
tfx/orchestration/portable/tfx_runner.py	58
tfx/orchestration/publisher.py	21
tfx/orchestration/python_execution_binary/__init__.py	1
tfx/orchestration/python_execution_binary/entrypoint.py	78
tfx/orchestration/python_execution_binary/python_execution_binary_utils.py	48
tfx/orchestration/tfx_runner.py	14