Path Lines of Code tfx/components/bulk_inferrer/component_test.py 32 tfx/components/bulk_inferrer/executor_test.py 134 tfx/components/bulk_inferrer/prediction_to_example_utils_test.py 86 tfx/components/distribution_validator/component_test.py 35 tfx/components/distribution_validator/executor_test.py 565 tfx/components/distribution_validator/utils_test.py 25 tfx/components/evaluator/component_test.py 117 tfx/components/evaluator/executor_test.py 295 tfx/components/example_diff/component_test.py 33 tfx/components/example_diff/executor_test.py 153 tfx/components/example_gen/base_example_gen_executor_test.py 204 tfx/components/example_gen/component_test.py 178 tfx/components/example_gen/csv_example_gen/component_test.py 8 tfx/components/example_gen/csv_example_gen/executor_test.py 111 tfx/components/example_gen/custom_executors/avro_component_test.py 61 tfx/components/example_gen/custom_executors/avro_executor_test.py 70 tfx/components/example_gen/custom_executors/parquet_component_test.py 62 tfx/components/example_gen/custom_executors/parquet_executor_test.py 70 tfx/components/example_gen/driver_test.py 279 tfx/components/example_gen/import_example_gen/component_test.py 8 tfx/components/example_gen/import_example_gen/executor_test.py 113 tfx/components/example_gen/input_processor_test.py 97 tfx/components/example_gen/utils_test.py 562 tfx/components/example_gen/write_split_test.py 85 tfx/components/example_validator/component_test.py 23 tfx/components/example_validator/executor_test.py 129 tfx/components/experimental/data_view/binder_component_test.py 15 tfx/components/experimental/data_view/binder_executor_test.py 41 tfx/components/experimental/data_view/provider_component_test.py 26 tfx/components/experimental/data_view/provider_executor_test.py 47 tfx/components/infra_validator/component_test.py 25 tfx/components/infra_validator/executor_test.py 241 tfx/components/infra_validator/model_server_clients/tensorflow_serving_client_test.py 102 tfx/components/infra_validator/model_server_runners/kubernetes_runner_test.py 257 tfx/components/infra_validator/model_server_runners/local_docker_runner_test.py 142 tfx/components/infra_validator/request_builder_test.py 413 tfx/components/infra_validator/serving_bins_test.py 28 tfx/components/model_validator/component_test.py 13 tfx/components/model_validator/driver_test.py 47 tfx/components/model_validator/executor_test.py 58 tfx/components/pusher/component_test.py 71 tfx/components/pusher/executor_test.py 170 tfx/components/schema_gen/component_test.py 39 tfx/components/schema_gen/executor_test.py 58 tfx/components/schema_gen/import_schema_gen/component_test.py 13 tfx/components/schema_gen/import_schema_gen/executor_test.py 47 tfx/components/statistics_gen/component_test.py 34 tfx/components/statistics_gen/executor_test.py 338 tfx/components/statistics_gen/stats_artifact_utils_test.py 20 tfx/components/trainer/component_test.py 155 tfx/components/trainer/executor_test.py 105 tfx/components/trainer/fn_args_utils_test.py 54 tfx/components/trainer/rewriting/rewriter_factory_test.py 26 tfx/components/trainer/rewriting/rewriter_test.py 75 tfx/components/trainer/rewriting/tfjs_rewriter_test.py 24 tfx/components/trainer/rewriting/tflite_rewriter_test.py 201 tfx/components/transform/component_test.py 203 tfx/components/transform/executor_on_parquet_test.py 65 tfx/components/transform/executor_sequence_example_test.py 26 tfx/components/transform/executor_test.py 578 tfx/components/transform/executor_utils_test.py 160 tfx/components/transform/executor_v2_sequence_example_test.py 8 tfx/components/transform/executor_v2_test.py 7 tfx/components/tuner/component_test.py 56 tfx/components/tuner/executor_test.py 140 tfx/components/util/examples_utils_test.py 62 tfx/components/util/tfxio_utils_test.py 313 tfx/components/util/udf_utils_test.py 115 tfx/components/util/value_utils_test.py 12 tfx/dsl/compiler/compiler_test.py 232 tfx/dsl/compiler/compiler_utils_test.py 237 tfx/dsl/compiler/node_contexts_compiler_test.py 39 tfx/dsl/compiler/node_execution_options_utils_test.py 41 tfx/dsl/compiler/node_inputs_compiler_test.py 504 tfx/dsl/compiler/placeholder_utils_test.py 874 tfx/dsl/component/experimental/annotations_test.py 77 tfx/dsl/component/experimental/component_utils_test.py 154 tfx/dsl/component/experimental/decorators_test.py 623 tfx/dsl/component/experimental/decorators_typeddict_test.py 665 tfx/dsl/component/experimental/executor_specs_test.py 64 tfx/dsl/component/experimental/function_parser_test.py 443 tfx/dsl/component/experimental/json_compat_test.py 148 tfx/dsl/component/experimental/utils_test.py 246 tfx/dsl/components/base/base_beam_component_test.py 30 tfx/dsl/components/base/base_beam_executor_test.py 53 tfx/dsl/components/base/base_component_test.py 200 tfx/dsl/components/base/base_driver_test.py 207 tfx/dsl/components/base/executor_spec_test.py 39 tfx/dsl/components/base/testing/test_node.py 8 tfx/dsl/components/common/importer_test.py 225 tfx/dsl/components/common/manual_node_test.py 11 tfx/dsl/components/common/resolver_test.py 158 tfx/dsl/context_managers/dsl_context_manager_test.py 126 tfx/dsl/context_managers/dsl_context_registry_test.py 117 tfx/dsl/context_managers/test_utils.py 63 tfx/dsl/control_flow/for_each_test.py 90 tfx/dsl/experimental/conditionals/conditional_test.py 63 tfx/dsl/experimental/node_execution_options/utils_test.py 52 tfx/dsl/hooks_test.py 58 tfx/dsl/input_resolution/canned_resolver_functions_test.py 498 tfx/dsl/input_resolution/ops/all_spans_op_test.py 32 tfx/dsl/input_resolution/ops/consecutive_spans_op_test.py 215 tfx/dsl/input_resolution/ops/equal_property_values_op_test.py 71 tfx/dsl/input_resolution/ops/exclude_spans_op_test.py 41 tfx/dsl/input_resolution/ops/graph_traversal_op_test.py 288 tfx/dsl/input_resolution/ops/group_by_lineage_op_test.py 279 tfx/dsl/input_resolution/ops/latest_create_time_op_test.py 27 tfx/dsl/input_resolution/ops/latest_pipeline_run_outputs_op_test.py 169 tfx/dsl/input_resolution/ops/latest_policy_model_op_test.py 588 tfx/dsl/input_resolution/ops/latest_span_op_test.py 251 tfx/dsl/input_resolution/ops/latest_version_op_test.py 66 tfx/dsl/input_resolution/ops/paired_spans_op_test.py 122 tfx/dsl/input_resolution/ops/shuffle_op_test.py 28 tfx/dsl/input_resolution/ops/siblings_op_test.py 191 tfx/dsl/input_resolution/ops/skip_if_empty_op_test.py 22 tfx/dsl/input_resolution/ops/skip_if_less_than_n_spans_op_test.py 37 tfx/dsl/input_resolution/ops/slice_op_test.py 39 tfx/dsl/input_resolution/ops/sliding_window_op_test.py 82 tfx/dsl/input_resolution/ops/span_driven_evaluator_inputs_op_test.py 497 tfx/dsl/input_resolution/ops/static_span_range_op_test.py 39 tfx/dsl/input_resolution/ops/test_utils.py 362 tfx/dsl/input_resolution/ops/training_range_op_test.py 137 tfx/dsl/input_resolution/ops/unnest_op_test.py 53 tfx/dsl/input_resolution/resolver_function_test.py 261 tfx/dsl/input_resolution/resolver_op_test.py 194 tfx/dsl/input_resolution/strategies/conditional_strategy_test.py 69 tfx/dsl/input_resolution/strategies/latest_artifact_strategy_test.py 27 tfx/dsl/input_resolution/strategies/latest_blessed_model_strategy_test.py 70 tfx/dsl/input_resolution/strategies/span_range_strategy_test.py 55 tfx/dsl/io/filesystem_registry_test.py 78 tfx/dsl/io/plugins/local_test.py 28 tfx/dsl/io/plugins/tensorflow_gfile_test.py 28 tfx/dsl/placeholder/placeholder_test.py 802 tfx/dsl/placeholder/proto_placeholder_test.py 776 tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/beam_pipeline_test.py 119 tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/execution_spec_test.py 14 tfx/experimental/distributed_inference/graphdef_experiments/subgraph_partitioning/graph_partition_test.py 74 tfx/experimental/pipeline_testing/pipeline_mock.py 41 tfx/experimental/pipeline_testing/pipeline_mock_test.py 17 tfx/experimental/pipeline_testing/pipeline_recorder_utils_test.py 101 tfx/experimental/pipeline_testing/stub_component_launcher_test.py 85 tfx/experimental/templates/penguin/e2e_tests/local_e2e_test.py 37 tfx/experimental/templates/penguin/models/features_test.py 5 tfx/experimental/templates/penguin/models/model_test.py 6 tfx/experimental/templates/penguin/models/preprocessing_test.py 5 tfx/experimental/templates/taxi/e2e_tests/local_e2e_test.py 35 tfx/experimental/templates/taxi/e2e_tests/vertex_e2e_test.py 34 tfx/experimental/templates/taxi/models/features_test.py 13 tfx/experimental/templates/taxi/models/keras_model/model_test.py 9 tfx/experimental/templates/taxi/models/preprocessing_test.py 5 tfx/experimental/templates/test_utils.py 125 tfx/extensions/experimental/kfp_compatibility/kfp_container_component_test.py 73 tfx/extensions/google_cloud_ai_platform/bulk_inferrer/component_test.py 29 tfx/extensions/google_cloud_ai_platform/bulk_inferrer/executor_test.py 206 tfx/extensions/google_cloud_ai_platform/prediction_clients_test.py 14 tfx/extensions/google_cloud_ai_platform/pusher/component_test.py 15 tfx/extensions/google_cloud_ai_platform/pusher/executor_test.py 255 tfx/extensions/google_cloud_ai_platform/runner_test.py 786 tfx/extensions/google_cloud_ai_platform/trainer/component_test.py 32 tfx/extensions/google_cloud_ai_platform/trainer/executor_test.py 90 tfx/extensions/google_cloud_ai_platform/tuner/component_test.py 41 tfx/extensions/google_cloud_ai_platform/tuner/executor_test.py 115 tfx/extensions/google_cloud_big_query/example_gen/component_test.py 48 tfx/extensions/google_cloud_big_query/example_gen/executor_test.py 137 tfx/extensions/google_cloud_big_query/experimental/elwc_example_gen/component/component_test.py 43 tfx/extensions/google_cloud_big_query/experimental/elwc_example_gen/component/executor_test.py 103 tfx/extensions/google_cloud_big_query/pusher/component_test.py 16 tfx/extensions/google_cloud_big_query/pusher/executor_test.py 88 tfx/extensions/google_cloud_big_query/utils_test.py 36 tfx/orchestration/airflow/airflow_component_test.py 104 tfx/orchestration/airflow/airflow_dag_runner_test.py 204 tfx/orchestration/airflow/test_utils.py 80 tfx/orchestration/beam/beam_dag_runner_test.py 216 tfx/orchestration/beam/legacy/beam_dag_runner_test.py 102 tfx/orchestration/config/config_utils_test.py 53 tfx/orchestration/config/docker_component_config_test.py 17 tfx/orchestration/config/pipeline_config_test.py 29 tfx/orchestration/data_types_test.py 86 tfx/orchestration/data_types_utils_test.py 291 tfx/orchestration/experimental/interactive/interactive_context_test.py 179 tfx/orchestration/experimental/interactive/notebook_formatters_test.py 29 tfx/orchestration/experimental/interactive/notebook_utils_test.py 20 tfx/orchestration/experimental/interactive/visualizations_test.py 27 tfx/orchestration/kubeflow/test_utils.py 207 tfx/orchestration/kubeflow/v2/compiler_utils_test.py 259 tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_component_integration_test.py 54 tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_component_test.py 131 tfx/orchestration/kubeflow/v2/components/experimental/ai_platform_training_executor_test.py 115 tfx/orchestration/kubeflow/v2/container/kubeflow_v2_entrypoint_utils_test.py 153 tfx/orchestration/kubeflow/v2/container/kubeflow_v2_run_executor_test.py 235 tfx/orchestration/kubeflow/v2/e2e_tests/artifact_value_placeholder_integration_test.py 57 tfx/orchestration/kubeflow/v2/e2e_tests/bigquery_integration_test.py 40 tfx/orchestration/kubeflow/v2/e2e_tests/csv_example_gen_integration_test.py 44 tfx/orchestration/kubeflow/v2/e2e_tests/exit_handler_e2e_test.py 55 tfx/orchestration/kubeflow/v2/file_based_example_gen/driver_test.py 215 tfx/orchestration/kubeflow/v2/kubeflow_v2_dag_runner_test.py 261 tfx/orchestration/kubeflow/v2/parameter_utils_test.py 39 tfx/orchestration/kubeflow/v2/pipeline_builder_test.py 298 tfx/orchestration/kubeflow/v2/step_builder_test.py 661 tfx/orchestration/kubeflow/v2/test_utils.py 588 tfx/orchestration/launcher/base_component_launcher_test.py 50 tfx/orchestration/launcher/container_common_test.py 69 tfx/orchestration/launcher/docker_component_launcher_e2e_test.py 63 tfx/orchestration/launcher/docker_component_launcher_test.py 98 tfx/orchestration/launcher/kubernetes_component_launcher_test.py 255 tfx/orchestration/launcher/test_utils.py 64 tfx/orchestration/local/legacy/local_dag_runner_test.py 119 tfx/orchestration/local/local_dag_runner_test.py 143 tfx/orchestration/local/local_pipeline_beam_test.py 65 tfx/orchestration/local/local_pipeline_test.py 138 tfx/orchestration/metadata_test.py 15 tfx/orchestration/mlmd_connection_manager_test.py 41 tfx/orchestration/pipeline_test.py 361 tfx/orchestration/portable/beam_executor_operator_test.py 40 tfx/orchestration/portable/cache_utils_test.py 211 tfx/orchestration/portable/docker_executor_operator_e2e_test.py 60 tfx/orchestration/portable/docker_executor_operator_test.py 84 tfx/orchestration/portable/execution/di_providers_test.py 193 tfx/orchestration/portable/execution_publish_utils_test.py 543 tfx/orchestration/portable/execution_watcher_test.py 70 tfx/orchestration/portable/importer_node_handler_test.py 145 tfx/orchestration/portable/input_resolution/channel_resolver_test.py 161 tfx/orchestration/portable/input_resolution/input_graph_resolver_test.py 139 tfx/orchestration/portable/input_resolution/mlmd_resolver/metadata_resolver_test.py 765 tfx/orchestration/portable/input_resolution/node_inputs_resolver_test.py 505 tfx/orchestration/portable/input_resolution/partition_utils_test.py 119 tfx/orchestration/portable/inputs_utils_test.py 252 tfx/orchestration/portable/kubernetes_executor_operator_test.py 174 tfx/orchestration/portable/launcher_test.py 822 tfx/orchestration/portable/merge_utils_test.py 232 tfx/orchestration/portable/mlmd/artifact_lib_test.py 101 tfx/orchestration/portable/mlmd/common_utils_test.py 68 tfx/orchestration/portable/mlmd/context_lib_test.py 141 tfx/orchestration/portable/mlmd/event_lib_test.py 326 tfx/orchestration/portable/mlmd/execution_lib_test.py 659 tfx/orchestration/portable/mlmd/store_ext_test.py 261 tfx/orchestration/portable/outputs_utils_test.py 275 tfx/orchestration/portable/partial_run_utils_test.py 939 tfx/orchestration/portable/python_driver_operator_test.py 21 tfx/orchestration/portable/python_executor_operator_test.py 94 tfx/orchestration/portable/resolver_node_handler_test.py 145 tfx/orchestration/portable/runtime_parameter_utils_test.py 65 tfx/orchestration/publisher_test.py 37 tfx/orchestration/python_execution_binary/python_execution_binary_utils_test.py 107 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 54 tfx/scripts/run_executor_test.py 47 tfx/tools/cli/cli_main_test.py 24 tfx/tools/cli/commands/pipeline_test.py 116 tfx/tools/cli/commands/run_test.py 135 tfx/tools/cli/commands/template_test.py 53 tfx/tools/cli/container_builder/builder_test.py 35 tfx/tools/cli/container_builder/dockerfile_test.py 50 tfx/tools/cli/e2e/__init__.py 1 tfx/tools/cli/e2e/cli_airflow_e2e_test.py 263 tfx/tools/cli/e2e/cli_beam_e2e_test.py 234 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 236 tfx/tools/cli/e2e/test_utils.py 46 tfx/tools/cli/handler/airflow_dag_runner_patcher_test.py 15 tfx/tools/cli/handler/airflow_handler_test.py 348 tfx/tools/cli/handler/base_handler_test.py 102 tfx/tools/cli/handler/beam_dag_runner_patcher_test.py 15 tfx/tools/cli/handler/beam_handler_test.py 281 tfx/tools/cli/handler/dag_runner_patcher_test.py 54 tfx/tools/cli/handler/handler_factory_test.py 65 tfx/tools/cli/handler/kubeflow_v2_dag_runner_patcher_test.py 41 tfx/tools/cli/handler/local_dag_runner_patcher_test.py 15 tfx/tools/cli/handler/local_handler_test.py 291 tfx/tools/cli/handler/template_handler_test.py 38 tfx/tools/cli/handler/vertex_handler_test.py 166 tfx/tools/cli/pip_utils_test.py 15 tfx/types/artifact_test.py 537 tfx/types/artifact_utils_test.py 168 tfx/types/channel_test.py 182 tfx/types/channel_utils_test.py 125 tfx/types/channel_wrapped_placeholder_test.py 473 tfx/types/component_spec_test.py 338 tfx/types/standard_artifact_utils_test.py 119 tfx/types/standard_artifacts_test.py 142 tfx/types/value_artifact_test.py 108 tfx/utils/channel_test.py 28 tfx/utils/dependency_utils_test.py 61 tfx/utils/deprecation_utils_test.py 88 tfx/utils/di/module_test.py 151 tfx/utils/doc_controls_test.py 15 tfx/utils/docker_utils_test.py 41 tfx/utils/import_utils_test.py 58 tfx/utils/io_utils_test.py 289 tfx/utils/json_utils_test.py 90 tfx/utils/logging_utils_test.py 32 tfx/utils/model_paths/tf_serving_flavor_test.py 49 tfx/utils/name_utils_test.py 37 tfx/utils/path_utils_test.py 72 tfx/utils/proto_utils_test.py 74 tfx/utils/pure_typing_utils_test.py 25 tfx/utils/retry_test.py 63 tfx/utils/telemetry_utils_test.py 75 tfx/utils/test_case_utils.py 319 tfx/utils/test_case_utils_test.py 78 tfx/utils/topsort_test.py 114 tfx/utils/typing_utils_test.py 206 tfx/utils/version_utils_test.py 10 tfx/utils/writer_utils_test.py 20