Path	Lines of Code
tfx/components/bulk_inferrer/component_test.py	34
tfx/components/bulk_inferrer/executor_test.py	136
tfx/components/bulk_inferrer/prediction_to_example_utils_test.py	88
tfx/components/distribution_validator/component_test.py	37
tfx/components/distribution_validator/executor_test.py	327
tfx/components/evaluator/component_test.py	119
tfx/components/evaluator/executor_test.py	297
tfx/components/example_diff/component_test.py	35
tfx/components/example_diff/executor_test.py	156
tfx/components/example_gen/base_example_gen_executor_test.py	206
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	115
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	87
tfx/components/example_validator/component_test.py	25
tfx/components/example_validator/executor_test.py	96
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	49
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	268
tfx/components/infra_validator/model_server_runners/local_docker_runner_test.py	144
tfx/components/infra_validator/request_builder_test.py	415
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	57
tfx/components/pusher/component_test.py	73
tfx/components/pusher/executor_test.py	172
tfx/components/schema_gen/component_test.py	41
tfx/components/schema_gen/executor_test.py	60
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	183
tfx/components/statistics_gen/stats_artifact_utils_test.py	22
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	125
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	26
tfx/components/trainer/rewriting/tflite_rewriter_test.py	203
tfx/components/transform/component_test.py	205
tfx/components/transform/executor_on_parquet_test.py	64
tfx/components/transform/executor_sequence_example_test.py	29
tfx/components/transform/executor_test.py	524
tfx/components/transform/executor_utils_test.py	162
tfx/components/transform/executor_v2_sequence_example_test.py	11
tfx/components/transform/executor_v2_test.py	10
tfx/components/tuner/component_test.py	58
tfx/components/tuner/executor_test.py	142
tfx/components/util/examples_utils_test.py	46
tfx/components/util/tfxio_utils_test.py	315
tfx/components/util/udf_utils_test.py	117
tfx/components/util/value_utils_test.py	14
tfx/dsl/compiler/compiler_test.py	172
tfx/dsl/compiler/compiler_utils_test.py	147
tfx/dsl/compiler/node_inputs_compiler_test.py	299
tfx/dsl/compiler/placeholder_utils_test.py	602
tfx/dsl/component/experimental/annotations_test.py	68
tfx/dsl/component/experimental/decorators_test.py	565
tfx/dsl/component/experimental/executor_specs_test.py	66
tfx/dsl/component/experimental/function_parser_test.py	401
tfx/dsl/component/experimental/json_compat_test.py	149
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	202
tfx/dsl/components/base/base_driver_test.py	209
tfx/dsl/components/base/executor_spec_test.py	41
tfx/dsl/components/common/importer_test.py	197
tfx/dsl/components/common/manual_node_test.py	13
tfx/dsl/components/common/resolver_test.py	160
tfx/dsl/context_managers/dsl_context_manager_test.py	129
tfx/dsl/control_flow/for_each_test.py	84
tfx/dsl/experimental/conditionals/conditional_test.py	59
tfx/dsl/experimental/node_execution_options/utils_test.py	45
tfx/dsl/input_resolution/canned_resolver_functions_test.py	277
tfx/dsl/input_resolution/ops/all_spans_op_test.py	34
tfx/dsl/input_resolution/ops/consecutive_spans_op_test.py	217
tfx/dsl/input_resolution/ops/exclude_spans_op_test.py	43
tfx/dsl/input_resolution/ops/group_by_lineage_op_test.py	281
tfx/dsl/input_resolution/ops/latest_create_time_op_test.py	29
tfx/dsl/input_resolution/ops/latest_pipeline_run_outputs_op_test.py	168
tfx/dsl/input_resolution/ops/latest_policy_model_op_test.py	472
tfx/dsl/input_resolution/ops/latest_span_op_test.py	186
tfx/dsl/input_resolution/ops/latest_version_op_test.py	68
tfx/dsl/input_resolution/ops/shuffle_op_test.py	30
tfx/dsl/input_resolution/ops/skip_if_empty_op_test.py	24
tfx/dsl/input_resolution/ops/skip_if_less_than_n_spans_op_test.py	39
tfx/dsl/input_resolution/ops/sliding_window_op_test.py	75
tfx/dsl/input_resolution/ops/span_driven_evaluator_inputs_op_test.py	500
tfx/dsl/input_resolution/ops/static_span_range_op_test.py	41
tfx/dsl/input_resolution/ops/test_utils.py	275
tfx/dsl/input_resolution/ops/training_range_op_test.py	121
tfx/dsl/input_resolution/ops/unnest_op_test.py	55
tfx/dsl/input_resolution/resolver_function_test.py	263
tfx/dsl/input_resolution/resolver_op_test.py	196
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	73
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	180
tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/beam_pipeline_test.py	121
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	76
tfx/experimental/pipeline_testing/pipeline_mock.py	41
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	87
tfx/experimental/templates/penguin/e2e_tests/kubeflow_e2e_test.py	27
tfx/experimental/templates/penguin/e2e_tests/local_e2e_test.py	38
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	24
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	208
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	257
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	92
tfx/extensions/google_cloud_ai_platform/tuner/component_test.py	43
tfx/extensions/google_cloud_ai_platform/tuner/executor_test.py	117
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	105
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	106
tfx/orchestration/airflow/airflow_dag_runner_test.py	206
tfx/orchestration/airflow/test_utils.py	72
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	288
tfx/orchestration/experimental/centralized_kubernetes_orchestrator/service/kubernetes_orchestrator_service_test.py	63
tfx/orchestration/experimental/core/async_pipeline_task_gen_test.py	579
tfx/orchestration/experimental/core/env_test.py	24
tfx/orchestration/experimental/core/garbage_collection_test.py	239
tfx/orchestration/experimental/core/mlmd_state_test.py	113
tfx/orchestration/experimental/core/pipeline_ops_test.py	2173
tfx/orchestration/experimental/core/pipeline_state_test.py	923
tfx/orchestration/experimental/core/post_execution_utils_test.py	83
tfx/orchestration/experimental/core/service_jobs_test.py	54
tfx/orchestration/experimental/core/sync_pipeline_task_gen_test.py	727
tfx/orchestration/experimental/core/task_gen_utils_test.py	535
tfx/orchestration/experimental/core/task_manager_test.py	441
tfx/orchestration/experimental/core/task_queue_test.py	42
tfx/orchestration/experimental/core/task_scheduler_test.py	83
tfx/orchestration/experimental/core/task_schedulers/importer_task_scheduler_test.py	82
tfx/orchestration/experimental/core/task_schedulers/manual_task_scheduler_test.py	83
tfx/orchestration/experimental/core/task_schedulers/resolver_task_scheduler_test.py	104
tfx/orchestration/experimental/core/task_schedulers/subpipeline_task_scheduler_test.py	149
tfx/orchestration/experimental/core/task_test.py	28
tfx/orchestration/experimental/core/test_utils.py	379
tfx/orchestration/experimental/core/testing/test_async_pipeline.py	50
tfx/orchestration/experimental/core/testing/test_dynamic_exec_properties_pipeline.py	53
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	41
tfx/orchestration/experimental/core/testing/test_subpipeline.py	49
tfx/orchestration/experimental/core/testing/test_sync_pipeline.py	105
tfx/orchestration/experimental/interactive/interactive_context_test.py	181
tfx/orchestration/experimental/interactive/notebook_formatters_test.py	31
tfx/orchestration/experimental/interactive/notebook_utils_test.py	22
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	197
tfx/orchestration/kubeflow/e2e_tests/kubeflow_dataflow_integration_test.py	73
tfx/orchestration/kubeflow/e2e_tests/kubeflow_e2e_test.py	194
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	258
tfx/orchestration/kubeflow/test_utils.py	392
tfx/orchestration/kubeflow/v2/compiler_utils_test.py	236
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	211
tfx/orchestration/kubeflow/v2/e2e_tests/artifact_value_placeholder_integration_test.py	51
tfx/orchestration/kubeflow/v2/e2e_tests/bigquery_integration_test.py	31
tfx/orchestration/kubeflow/v2/e2e_tests/csv_example_gen_integration_test.py	29
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	74
tfx/orchestration/kubeflow/v2/parameter_utils_test.py	41
tfx/orchestration/kubeflow/v2/pipeline_builder_test.py	129
tfx/orchestration/kubeflow/v2/step_builder_test.py	411
tfx/orchestration/kubeflow/v2/test_utils.py	543
tfx/orchestration/launcher/base_component_launcher_test.py	52
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_beam_test.py	67
tfx/orchestration/local/local_pipeline_test.py	140
tfx/orchestration/metadata_test.py	18
tfx/orchestration/mlmd_connection_manager_test.py	43
tfx/orchestration/pipeline_test.py	329
tfx/orchestration/portable/beam_executor_operator_test.py	43
tfx/orchestration/portable/cache_utils_test.py	199
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	438
tfx/orchestration/portable/execution_watcher_test.py	67
tfx/orchestration/portable/importer_node_handler_test.py	123
tfx/orchestration/portable/input_resolution/channel_resolver_test.py	164
tfx/orchestration/portable/input_resolution/input_graph_resolver_test.py	141
tfx/orchestration/portable/input_resolution/node_inputs_resolver_test.py	451
tfx/orchestration/portable/input_resolution/partition_utils_test.py	121
tfx/orchestration/portable/inputs_utils_test.py	204
tfx/orchestration/portable/kubernetes_executor_operator_test.py	176
tfx/orchestration/portable/launcher_test.py	727
tfx/orchestration/portable/merge_utils_test.py	235
tfx/orchestration/portable/mlmd/artifact_lib_test.py	104
tfx/orchestration/portable/mlmd/common_utils_test.py	55
tfx/orchestration/portable/mlmd/context_lib_test.py	133
tfx/orchestration/portable/mlmd/event_lib_test.py	314
tfx/orchestration/portable/mlmd/execution_lib_test.py	621
tfx/orchestration/portable/mlmd/store_ext_test.py	84
tfx/orchestration/portable/outputs_utils_test.py	256
tfx/orchestration/portable/partial_run_utils_test.py	889
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	130
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	62
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	259
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	485
tfx/types/artifact_utils_test.py	170
tfx/types/channel_test.py	144
tfx/types/channel_utils_test.py	56
tfx/types/channel_wrapped_placeholder_test.py	286
tfx/types/component_spec_test.py	323
tfx/types/standard_artifacts_test.py	113
tfx/types/value_artifact_test.py	110
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	92
tfx/utils/logging_utils_test.py	34
tfx/utils/model_paths/tf_serving_flavor_test.py	51
tfx/utils/name_utils_test.py	39
tfx/utils/path_utils_test.py	74
tfx/utils/proto_utils_test.py	77
tfx/utils/retry_test.py	65
tfx/utils/telemetry_utils_test.py	77
tfx/utils/test_case_utils.py	266
tfx/utils/test_case_utils_test.py	81
tfx/utils/topsort_test.py	116
tfx/utils/typing_utils_test.py	145
tfx/utils/version_utils_test.py	12
tfx/utils/writer_utils_test.py	22