Path	Lines of Code
tfx/components/bulk_inferrer/component_test.py	34
tfx/components/bulk_inferrer/executor_test.py	139
tfx/components/bulk_inferrer/prediction_to_example_utils_test.py	73
tfx/components/evaluator/component_test.py	119
tfx/components/evaluator/executor_test.py	300
tfx/components/example_gen/base_example_gen_executor_test.py	168
tfx/components/example_gen/component_test.py	180
tfx/components/example_gen/csv_example_gen/component_test.py	10
tfx/components/example_gen/csv_example_gen/executor_test.py	113
tfx/components/example_gen/custom_executors/avro_component_test.py	63
tfx/components/example_gen/custom_executors/avro_executor_test.py	72
tfx/components/example_gen/custom_executors/parquet_component_test.py	64
tfx/components/example_gen/custom_executors/parquet_executor_test.py	72
tfx/components/example_gen/driver_test.py	281
tfx/components/example_gen/import_example_gen/component_test.py	10
tfx/components/example_gen/import_example_gen/executor_test.py	101
tfx/components/example_gen/input_processor_test.py	99
tfx/components/example_gen/utils_test.py	564
tfx/components/example_gen/write_split_test.py	56
tfx/components/example_validator/component_test.py	25
tfx/components/example_validator/executor_test.py	59
tfx/components/experimental/data_view/binder_component_test.py	17
tfx/components/experimental/data_view/binder_executor_test.py	43
tfx/components/experimental/data_view/provider_component_test.py	28
tfx/components/experimental/data_view/provider_executor_test.py	53
tfx/components/infra_validator/component_test.py	27
tfx/components/infra_validator/executor_test.py	243
tfx/components/infra_validator/model_server_clients/tensorflow_serving_client_test.py	104
tfx/components/infra_validator/model_server_runners/kubernetes_runner_test.py	246
tfx/components/infra_validator/model_server_runners/local_docker_runner_test.py	139
tfx/components/infra_validator/request_builder_test.py	431
tfx/components/infra_validator/serving_bins_test.py	30
tfx/components/model_validator/component_test.py	15
tfx/components/model_validator/driver_test.py	49
tfx/components/model_validator/executor_test.py	60
tfx/components/pusher/component_test.py	73
tfx/components/pusher/executor_test.py	161
tfx/components/schema_gen/component_test.py	41
tfx/components/schema_gen/executor_test.py	36
tfx/components/schema_gen/import_schema_gen/component_test.py	15
tfx/components/schema_gen/import_schema_gen/executor_test.py	49
tfx/components/statistics_gen/component_test.py	36
tfx/components/statistics_gen/executor_test.py	120
tfx/components/trainer/component_test.py	178
tfx/components/trainer/executor_test.py	173
tfx/components/trainer/fn_args_utils_test.py	56
tfx/components/trainer/rewriting/converters_test.py	124
tfx/components/trainer/rewriting/rewriter_factory_test.py	29
tfx/components/trainer/rewriting/rewriter_test.py	77
tfx/components/trainer/rewriting/tfjs_rewriter_test.py	29
tfx/components/trainer/rewriting/tflite_rewriter_test.py	203
tfx/components/transform/component_test.py	205
tfx/components/transform/executor_test.py	458
tfx/components/transform/executor_utils_test.py	162
tfx/components/transform/executor_v2_test.py	10
tfx/components/tuner/component_test.py	56
tfx/components/tuner/executor_test.py	134
tfx/components/util/examples_utils_test.py	36
tfx/components/util/tfxio_utils_test.py	286
tfx/components/util/udf_utils_test.py	117
tfx/components/util/value_utils_test.py	14
tfx/dsl/compiler/compiler_resolver_node_test.py	307
tfx/dsl/compiler/compiler_test.py	72
tfx/dsl/compiler/compiler_utils_test.py	106
tfx/dsl/compiler/placeholder_utils_test.py	569
tfx/dsl/component/experimental/annotations_test.py	46
tfx/dsl/component/experimental/decorators_test.py	215
tfx/dsl/component/experimental/executor_specs_test.py	66
tfx/dsl/component/experimental/function_parser_test.py	347
tfx/dsl/components/base/base_beam_component_test.py	32
tfx/dsl/components/base/base_beam_executor_test.py	51
tfx/dsl/components/base/base_component_test.py	186
tfx/dsl/components/base/base_driver_test.py	178
tfx/dsl/components/base/executor_spec_test.py	43
tfx/dsl/components/common/importer_test.py	126
tfx/dsl/components/common/manual_node_test.py	13
tfx/dsl/components/common/resolver_test.py	152
tfx/dsl/context_managers/context_manager_test.py	162
tfx/dsl/control_flow/for_each_test.py	89
tfx/dsl/experimental/conditionals/conditional_test.py	54
tfx/dsl/input_resolution/ops/skip_if_empty_op_test.py	21
tfx/dsl/input_resolution/ops/test_utils.py	16
tfx/dsl/input_resolution/ops/unnest_op_test.py	46
tfx/dsl/input_resolution/resolver_function_test.py	46
tfx/dsl/input_resolution/resolver_op_test.py	126
tfx/dsl/input_resolution/strategies/conditional_strategy_test.py	61
tfx/dsl/input_resolution/strategies/latest_artifact_strategy_test.py	30
tfx/dsl/input_resolution/strategies/latest_blessed_model_strategy_test.py	47
tfx/dsl/input_resolution/strategies/span_range_strategy_test.py	58
tfx/dsl/io/filesystem_registry_test.py	80
tfx/dsl/io/plugins/local_test.py	30
tfx/dsl/io/plugins/tensorflow_gfile_test.py	30
tfx/dsl/placeholder/placeholder_test.py	379
tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/beam_pipeline_test.py	123
tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/execution_spec_test.py	16
tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/graph_partition_test.py	79
tfx/experimental/pipeline_testing/pipeline_mock_test.py	19
tfx/experimental/pipeline_testing/pipeline_recorder_utils_test.py	103
tfx/experimental/pipeline_testing/stub_component_launcher_test.py	89
tfx/experimental/templates/penguin/e2e_tests/kubeflow_e2e_test.py	27
tfx/experimental/templates/penguin/e2e_tests/local_e2e_test.py	41
tfx/experimental/templates/penguin/models/features_test.py	7
tfx/experimental/templates/penguin/models/model_test.py	8
tfx/experimental/templates/penguin/models/preprocessing_test.py	7
tfx/experimental/templates/taxi/e2e_tests/kubeflow_e2e_test.py	68
tfx/experimental/templates/taxi/e2e_tests/local_e2e_test.py	35
tfx/experimental/templates/taxi/e2e_tests/vertex_e2e_test.py	35
tfx/experimental/templates/taxi/models/estimator_model/model_test.py	23
tfx/experimental/templates/taxi/models/features_test.py	15
tfx/experimental/templates/taxi/models/keras_model/model_test.py	11
tfx/experimental/templates/taxi/models/preprocessing_test.py	7
tfx/experimental/templates/test_utils.py	125
tfx/extensions/experimental/kfp_compatibility/kfp_container_component_test.py	75
tfx/extensions/google_cloud_ai_platform/bulk_inferrer/component_test.py	31
tfx/extensions/google_cloud_ai_platform/bulk_inferrer/executor_test.py	209
tfx/extensions/google_cloud_ai_platform/prediction_clients_test.py	16
tfx/extensions/google_cloud_ai_platform/pusher/component_test.py	17
tfx/extensions/google_cloud_ai_platform/pusher/executor_test.py	260
tfx/extensions/google_cloud_ai_platform/runner_test.py	782
tfx/extensions/google_cloud_ai_platform/trainer/component_test.py	34
tfx/extensions/google_cloud_ai_platform/trainer/executor_test.py	93
tfx/extensions/google_cloud_ai_platform/tuner/component_test.py	43
tfx/extensions/google_cloud_ai_platform/tuner/executor_test.py	114
tfx/extensions/google_cloud_big_query/example_gen/component_test.py	50
tfx/extensions/google_cloud_big_query/example_gen/executor_test.py	131
tfx/extensions/google_cloud_big_query/experimental/elwc_example_gen/component/component_test.py	45
tfx/extensions/google_cloud_big_query/experimental/elwc_example_gen/component/executor_test.py	100
tfx/extensions/google_cloud_big_query/pusher/component_test.py	18
tfx/extensions/google_cloud_big_query/pusher/executor_test.py	90
tfx/extensions/google_cloud_big_query/utils_test.py	38
tfx/orchestration/airflow/airflow_component_test.py	104
tfx/orchestration/airflow/airflow_dag_runner_test.py	206
tfx/orchestration/airflow/test_utils.py	55
tfx/orchestration/beam/beam_dag_runner_test.py	219
tfx/orchestration/beam/legacy/beam_dag_runner_test.py	104
tfx/orchestration/config/config_utils_test.py	55
tfx/orchestration/config/docker_component_config_test.py	19
tfx/orchestration/config/pipeline_config_test.py	31
tfx/orchestration/data_types_test.py	88
tfx/orchestration/data_types_utils_test.py	187
tfx/orchestration/experimental/core/async_pipeline_task_gen_test.py	372
tfx/orchestration/experimental/core/env_test.py	16
tfx/orchestration/experimental/core/mlmd_state_test.py	83
tfx/orchestration/experimental/core/pipeline_ops_test.py	964
tfx/orchestration/experimental/core/pipeline_state_test.py	476
tfx/orchestration/experimental/core/service_jobs_test.py	54
tfx/orchestration/experimental/core/sync_pipeline_task_gen_test.py	551
tfx/orchestration/experimental/core/task_gen_utils_test.py	155
tfx/orchestration/experimental/core/task_manager_test.py	380
tfx/orchestration/experimental/core/task_queue_test.py	42
tfx/orchestration/experimental/core/task_scheduler_test.py	66
tfx/orchestration/experimental/core/task_schedulers/importer_task_scheduler_test.py	86
tfx/orchestration/experimental/core/task_schedulers/manual_task_scheduler_test.py	86
tfx/orchestration/experimental/core/task_schedulers/resolver_task_scheduler_test.py	105
tfx/orchestration/experimental/core/task_test.py	28
tfx/orchestration/experimental/core/test_utils.py	256
tfx/orchestration/experimental/core/testing/test_async_pipeline.py	47
tfx/orchestration/experimental/core/testing/test_manual_node.py	15
tfx/orchestration/experimental/core/testing/test_pipeline_with_importer.py	21
tfx/orchestration/experimental/core/testing/test_pipeline_with_resolver.py	39
tfx/orchestration/experimental/core/testing/test_sync_pipeline.py	87
tfx/orchestration/experimental/interactive/interactive_context_test.py	194
tfx/orchestration/experimental/interactive/notebook_formatters_test.py	31
tfx/orchestration/experimental/interactive/visualizations_test.py	29
tfx/orchestration/experimental/kubernetes/kubernetes_dag_runner_test.py	135
tfx/orchestration/experimental/kubernetes/kubernetes_remote_runner_test.py	116
tfx/orchestration/kubeflow/base_component_test.py	172
tfx/orchestration/kubeflow/container_entrypoint_test.py	154
tfx/orchestration/kubeflow/e2e_tests/kubeflow_dataflow_integration_test.py	73
tfx/orchestration/kubeflow/e2e_tests/kubeflow_e2e_test.py	183
tfx/orchestration/kubeflow/e2e_tests/kubeflow_gcp_integration_test.py	388
tfx/orchestration/kubeflow/e2e_tests/kubeflow_gcp_perf_test.py	143
tfx/orchestration/kubeflow/kubeflow_dag_runner_test.py	228
tfx/orchestration/kubeflow/test_utils.py	393
tfx/orchestration/kubeflow/v2/compiler_utils_test.py	203
tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_component_integration_test.py	47
tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_component_test.py	133
tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_executor_test.py	118
tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils_test.py	117
tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor_test.py	124
tfx/orchestration/kubeflow/v2/e2e_tests/artifact_value_placeholder_integration_test.py	51
tfx/orchestration/kubeflow/v2/e2e_tests/bigquery_integration_test.py	26
tfx/orchestration/kubeflow/v2/e2e_tests/csv_example_gen_integration_test.py	24
tfx/orchestration/kubeflow/v2/e2e_tests/exit_handler_e2e_test.py	45
tfx/orchestration/kubeflow/v2/file_based_example_gen/driver_test.py	137
tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner_test.py	69
tfx/orchestration/kubeflow/v2/parameter_utils_test.py	41
tfx/orchestration/kubeflow/v2/pipeline_builder_test.py	121
tfx/orchestration/kubeflow/v2/step_builder_test.py	358
tfx/orchestration/kubeflow/v2/test_utils.py	511
tfx/orchestration/launcher/base_component_launcher_test.py	53
tfx/orchestration/launcher/container_common_test.py	71
tfx/orchestration/launcher/docker_component_launcher_e2e_test.py	62
tfx/orchestration/launcher/docker_component_launcher_test.py	100
tfx/orchestration/launcher/kubernetes_component_launcher_test.py	257
tfx/orchestration/launcher/test_utils.py	64
tfx/orchestration/local/legacy/local_dag_runner_test.py	121
tfx/orchestration/local/local_dag_runner_test.py	145
tfx/orchestration/local/local_pipeline_test.py	140
tfx/orchestration/metadata_test.py	18
tfx/orchestration/pipeline_test.py	274
tfx/orchestration/portable/beam_executor_operator_test.py	43
tfx/orchestration/portable/cache_utils_test.py	193
tfx/orchestration/portable/docker_executor_operator_e2e_test.py	61
tfx/orchestration/portable/docker_executor_operator_test.py	86
tfx/orchestration/portable/execution_publish_utils_test.py	349
tfx/orchestration/portable/execution_watcher_test.py	66
tfx/orchestration/portable/importer_node_handler_test.py	123
tfx/orchestration/portable/input_resolution/processor_test.py	131
tfx/orchestration/portable/inputs_utils_test.py	478
tfx/orchestration/portable/kubernetes_executor_operator_test.py	176
tfx/orchestration/portable/launcher_test.py	651
tfx/orchestration/portable/mlmd/common_utils_test.py	55
tfx/orchestration/portable/mlmd/context_lib_test.py	84
tfx/orchestration/portable/mlmd/event_lib_test.py	55
tfx/orchestration/portable/mlmd/execution_lib_test.py	251
tfx/orchestration/portable/outputs_utils_test.py	169
tfx/orchestration/portable/partial_run_utils_test.py	803
tfx/orchestration/portable/python_driver_operator_test.py	23
tfx/orchestration/portable/python_executor_operator_test.py	97
tfx/orchestration/portable/resolver_node_handler_test.py	127
tfx/orchestration/portable/runtime_parameter_utils_test.py	68
tfx/orchestration/publisher_test.py	39
tfx/orchestration/python_execution_binary/python_execution_binary_utils_test.py	76
tfx/orchestration/test_pipelines/__init__.py	1
tfx/orchestration/test_pipelines/custom_exit_handler.py	7
tfx/orchestration/test_pipelines/download_grep_print_pipeline.py	93
tfx/orchestration/test_utils.py	63
tfx/scripts/run_component_test.py	57
tfx/scripts/run_executor_test.py	49
tfx/tools/cli/cli_main_test.py	26
tfx/tools/cli/commands/pipeline_test.py	119
tfx/tools/cli/commands/run_test.py	138
tfx/tools/cli/commands/template_test.py	55
tfx/tools/cli/container_builder/builder_test.py	37
tfx/tools/cli/container_builder/dockerfile_test.py	53
tfx/tools/cli/e2e/__init__.py	1
tfx/tools/cli/e2e/cli_airflow_e2e_test.py	257
tfx/tools/cli/e2e/cli_beam_e2e_test.py	235
tfx/tools/cli/e2e/cli_common_e2e_test.py	43
tfx/tools/cli/e2e/cli_kubeflow_e2e_test.py	297
tfx/tools/cli/e2e/cli_local_e2e_test.py	237
tfx/tools/cli/e2e/test_utils.py	46
tfx/tools/cli/handler/airflow_dag_runner_patcher_test.py	17
tfx/tools/cli/handler/airflow_handler_test.py	351
tfx/tools/cli/handler/base_handler_test.py	104
tfx/tools/cli/handler/beam_dag_runner_patcher_test.py	17
tfx/tools/cli/handler/beam_handler_test.py	284
tfx/tools/cli/handler/dag_runner_patcher_test.py	56
tfx/tools/cli/handler/handler_factory_test.py	82
tfx/tools/cli/handler/kubeflow_dag_runner_patcher_test.py	46
tfx/tools/cli/handler/kubeflow_handler_test.py	217
tfx/tools/cli/handler/kubeflow_v2_dag_runner_patcher_test.py	44
tfx/tools/cli/handler/local_dag_runner_patcher_test.py	17
tfx/tools/cli/handler/local_handler_test.py	294
tfx/tools/cli/handler/template_handler_test.py	54
tfx/tools/cli/handler/vertex_handler_test.py	169
tfx/tools/cli/pip_utils_test.py	17
tfx/types/artifact_test.py	382
tfx/types/artifact_utils_test.py	126
tfx/types/channel_test.py	79
tfx/types/channel_utils_test.py	41
tfx/types/component_spec_test.py	296
tfx/types/standard_artifacts_test.py	71
tfx/types/value_artifact_test.py	66
tfx/utils/channel_test.py	31
tfx/utils/dependency_utils_test.py	63
tfx/utils/deprecation_utils_test.py	91
tfx/utils/doc_controls_test.py	16
tfx/utils/docker_utils_test.py	43
tfx/utils/import_utils_test.py	60
tfx/utils/io_utils_test.py	291
tfx/utils/json_utils_test.py	49
tfx/utils/logging_utils_test.py	34
tfx/utils/model_paths/tf_serving_flavor_test.py	51
tfx/utils/path_utils_test.py	74
tfx/utils/proto_utils_test.py	69
tfx/utils/retry_test.py	65
tfx/utils/telemetry_utils_test.py	77
tfx/utils/test_case_utils.py	53
tfx/utils/test_case_utils_test.py	56
tfx/utils/topsort_test.py	116
tfx/utils/typing_utils_test.py	42
tfx/utils/version_utils_test.py	12