LICENSE
MANIFEST.in
README.md
pyproject.toml
setup.py
ml_pipelines_sdk.egg-info/PKG-INFO
ml_pipelines_sdk.egg-info/SOURCES.txt
ml_pipelines_sdk.egg-info/dependency_links.txt
ml_pipelines_sdk.egg-info/namespace_packages.txt
ml_pipelines_sdk.egg-info/requires.txt
ml_pipelines_sdk.egg-info/top_level.txt
tfx/__init__.py
tfx/conftest.py
tfx/dependencies.py
tfx/py.typed
tfx/version.py
tfx/components/testdata/__init__.py
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00000-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00001-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00002-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00003-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00004-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00005-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00006-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00007-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00008-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00009-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00010-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-eval/data_tfrecord-00011-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00000-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00001-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00002-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00003-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00004-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00005-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00006-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00007-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00008-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00009-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00010-of-00012.gz
tfx/components/testdata/csv_example_gen/Split-train/data_tfrecord-00011-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00000-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00001-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00002-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00003-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00004-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00005-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00006-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00007-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00008-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00009-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00010-of-00012.gz
tfx/components/testdata/csv_example_gen/unlabelled/data_tfrecord-00011-of-00012.gz
tfx/components/testdata/external/README.md
tfx/components/testdata/external/avro/data.avro
tfx/components/testdata/external/avro/generate_avro_file.py
tfx/components/testdata/external/csv/data.csv
tfx/components/testdata/external/csv/data2.csv
tfx/components/testdata/external/csv_empty/data.csv
tfx/components/testdata/external/csv_multi_line_string/data.csv
tfx/components/testdata/external/parquet/data.parquet
tfx/components/testdata/external/tfrecord/data_tfrecord-00000-of-00002.gz
tfx/components/testdata/external/tfrecord/data_tfrecord-00001-of-00002.gz
tfx/components/testdata/external/tfrecord_sequence/data_tfrecord-00000-of-00001.gz
tfx/components/testdata/model_validator/blessed/BLESSED
tfx/components/testdata/model_validator/not_blessed/NOT_BLESSED
tfx/components/testdata/module_file/__init__.py
tfx/components/testdata/module_file/data_view_module.py
tfx/components/testdata/module_file/evaluator_module.py
tfx/components/testdata/module_file/trainer_module.py
tfx/components/testdata/module_file/transform_sequence_module.py
tfx/components/testdata/module_file/tuner_module.py
tfx/components/testdata/penguin/data/Split-eval/data_tfrecord-00000-of-00001.gz
tfx/components/testdata/penguin/data/Split-train/data_tfrecord-00000-of-00001.gz
tfx/components/testdata/penguin/schema/schema.pbtxt
tfx/components/testdata/pusher/model_push/1584391735/saved_model.pb
tfx/components/testdata/pusher/model_push/1584391735/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/pusher/model_push/1584391735/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/pusher/model_push/1584391735/variables/variables.data-00000-of-00001
tfx/components/testdata/pusher/model_push/1584391735/variables/variables.index
tfx/components/testdata/schema_gen/schema.pbtxt
tfx/components/testdata/schema_gen_sequence/schema.pbtxt
tfx/components/testdata/statistics_gen/Split-eval/FeatureStats.pb
tfx/components/testdata/statistics_gen/Split-train/FeatureStats.pb
tfx/components/testdata/tfrecord_sequence/Split-eval/data_tfrecord_eval.gz
tfx/components/testdata/tfrecord_sequence/Split-train/data_tfrecord_train.gz
tfx/components/testdata/trainer/blessed/Format-TFMA/1646034758/saved_model.pb
tfx/components/testdata/trainer/blessed/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/trainer/blessed/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/trainer/blessed/Format-TFMA/1646034758/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/blessed/Format-TFMA/1646034758/variables/variables.index
tfx/components/testdata/trainer/current/Format-Serving/checkpoint
tfx/components/testdata/trainer/current/Format-Serving/events.out.tfevents.1646034739.jiyongjung.c.googlers.com
tfx/components/testdata/trainer/current/Format-Serving/graph.pbtxt
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-0.data-00000-of-00001
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-0.index
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-0.meta
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-1000.data-00000-of-00001
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-1000.index
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-1000.meta
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-999.data-00000-of-00001
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-999.index
tfx/components/testdata/trainer/current/Format-Serving/model.ckpt-999.meta
tfx/components/testdata/trainer/current/Format-Serving/eval_chicago-taxi-eval/events.out.tfevents.1646034751.jiyongjung.c.googlers.com
tfx/components/testdata/trainer/current/Format-Serving/export/chicago-taxi/1646034756/saved_model.pb
tfx/components/testdata/trainer/current/Format-Serving/export/chicago-taxi/1646034756/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/trainer/current/Format-Serving/export/chicago-taxi/1646034756/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/trainer/current/Format-Serving/export/chicago-taxi/1646034756/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/current/Format-Serving/export/chicago-taxi/1646034756/variables/variables.index
tfx/components/testdata/trainer/current/Format-TFMA/1646034758/saved_model.pb
tfx/components/testdata/trainer/current/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/trainer/current/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/trainer/current/Format-TFMA/1646034758/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/current/Format-TFMA/1646034758/variables/variables.index
tfx/components/testdata/trainer/keras/Format-Serving/saved_model.pb
tfx/components/testdata/trainer/keras/Format-Serving/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/keras/Format-Serving/variables/variables.index
tfx/components/testdata/trainer/previous/Format-Serving/checkpoint
tfx/components/testdata/trainer/previous/Format-Serving/events.out.tfevents.1646034739.jiyongjung.c.googlers.com
tfx/components/testdata/trainer/previous/Format-Serving/graph.pbtxt
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-0.data-00000-of-00001
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-0.index
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-0.meta
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-1000.data-00000-of-00001
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-1000.index
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-1000.meta
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-999.data-00000-of-00001
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-999.index
tfx/components/testdata/trainer/previous/Format-Serving/model.ckpt-999.meta
tfx/components/testdata/trainer/previous/Format-Serving/eval_chicago-taxi-eval/events.out.tfevents.1646034751.jiyongjung.c.googlers.com
tfx/components/testdata/trainer/previous/Format-Serving/export/chicago-taxi/1646034756/saved_model.pb
tfx/components/testdata/trainer/previous/Format-Serving/export/chicago-taxi/1646034756/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/trainer/previous/Format-Serving/export/chicago-taxi/1646034756/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/trainer/previous/Format-Serving/export/chicago-taxi/1646034756/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/previous/Format-Serving/export/chicago-taxi/1646034756/variables/variables.index
tfx/components/testdata/trainer/previous/Format-TFMA/1646034758/saved_model.pb
tfx/components/testdata/trainer/previous/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/trainer/previous/Format-TFMA/1646034758/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/trainer/previous/Format-TFMA/1646034758/variables/variables.data-00000-of-00001
tfx/components/testdata/trainer/previous/Format-TFMA/1646034758/variables/variables.index
tfx/components/testdata/transform/transform_graph/metadata/schema.pbtxt
tfx/components/testdata/transform/transform_graph/transform_fn/saved_model.pb
tfx/components/testdata/transform/transform_graph/transform_fn/assets/vocab_compute_and_apply_vocabulary_1_vocabulary
tfx/components/testdata/transform/transform_graph/transform_fn/assets/vocab_compute_and_apply_vocabulary_vocabulary
tfx/components/testdata/transform/transform_graph/transform_fn/variables/variables.data-00000-of-00001
tfx/components/testdata/transform/transform_graph/transform_fn/variables/variables.index
tfx/components/testdata/transform/transform_graph/transformed_metadata/asset_map
tfx/components/testdata/transform/transform_graph/transformed_metadata/schema.pbtxt
tfx/components/testdata/transform/transformed_examples/Split-eval/transformed_examples-00000-of-00001.gz
tfx/components/testdata/transform/transformed_examples/Split-train/transformed_examples-00000-of-00001.gz
tfx/dsl/__init__.py
tfx/dsl/hooks.py
tfx/dsl/hooks_test.py
tfx/dsl/compiler/__init__.py
tfx/dsl/compiler/compiler.py
tfx/dsl/compiler/compiler_context.py
tfx/dsl/compiler/compiler_test.py
tfx/dsl/compiler/compiler_utils.py
tfx/dsl/compiler/compiler_utils_test.py
tfx/dsl/compiler/constants.py
tfx/dsl/compiler/node_contexts_compiler.py
tfx/dsl/compiler/node_contexts_compiler_test.py
tfx/dsl/compiler/node_execution_options_utils.py
tfx/dsl/compiler/node_execution_options_utils_test.py
tfx/dsl/compiler/node_inputs_compiler.py
tfx/dsl/compiler/node_inputs_compiler_test.py
tfx/dsl/compiler/placeholder_utils.py
tfx/dsl/compiler/placeholder_utils_test.py
tfx/dsl/compiler/testdata/__init__.py
tfx/dsl/compiler/testdata/additional_properties_test_pipeline_async.py
tfx/dsl/compiler/testdata/channel_union_pipeline.py
tfx/dsl/compiler/testdata/composable_pipeline.py
tfx/dsl/compiler/testdata/composable_pipeline_async.py
tfx/dsl/compiler/testdata/conditional_pipeline.py
tfx/dsl/compiler/testdata/consumer_pipeline.py
tfx/dsl/compiler/testdata/consumer_pipeline_different_project.py
tfx/dsl/compiler/testdata/consumer_pipeline_with_tags.py
tfx/dsl/compiler/testdata/dynamic_exec_properties_pipeline.py
tfx/dsl/compiler/testdata/external_artifacts_pipeline.py
tfx/dsl/compiler/testdata/foreach_pipeline.py
tfx/dsl/compiler/testdata/iris_pipeline_async.py
tfx/dsl/compiler/testdata/iris_pipeline_sync.py
tfx/dsl/compiler/testdata/non_existent_component_pipeline.py
tfx/dsl/compiler/testdata/optional_and_allow_empty_pipeline.py
tfx/dsl/compiler/testdata/pipeline_root_placeholder.py
tfx/dsl/compiler/testdata/pipeline_with_annotations.py
tfx/dsl/compiler/testdata/resolver_function_pipeline.py
tfx/dsl/component/__init__.py
tfx/dsl/component/experimental/__init__.py
tfx/dsl/component/experimental/annotations.py
tfx/dsl/component/experimental/annotations_test.py
tfx/dsl/component/experimental/component_utils.py
tfx/dsl/component/experimental/component_utils_test.py
tfx/dsl/component/experimental/container_component.py
tfx/dsl/component/experimental/decorators.py
tfx/dsl/component/experimental/decorators_test.py
tfx/dsl/component/experimental/decorators_typeddict_test.py
tfx/dsl/component/experimental/executor_specs.py
tfx/dsl/component/experimental/executor_specs_test.py
tfx/dsl/component/experimental/function_parser.py
tfx/dsl/component/experimental/function_parser_test.py
tfx/dsl/component/experimental/json_compat.py
tfx/dsl/component/experimental/json_compat_test.py
tfx/dsl/component/experimental/placeholders.py
tfx/dsl/component/experimental/utils.py
tfx/dsl/component/experimental/utils_test.py
tfx/dsl/components/__init__.py
tfx/dsl/components/base/__init__.py
tfx/dsl/components/base/base_beam_component.py
tfx/dsl/components/base/base_beam_component_test.py
tfx/dsl/components/base/base_beam_executor.py
tfx/dsl/components/base/base_beam_executor_test.py
tfx/dsl/components/base/base_component.py
tfx/dsl/components/base/base_component_test.py
tfx/dsl/components/base/base_driver.py
tfx/dsl/components/base/base_driver_test.py
tfx/dsl/components/base/base_executor.py
tfx/dsl/components/base/base_node.py
tfx/dsl/components/base/executor_spec.py
tfx/dsl/components/base/executor_spec_test.py
tfx/dsl/components/base/testing/test_node.py
tfx/dsl/components/common/__init__.py
tfx/dsl/components/common/importer.py
tfx/dsl/components/common/importer_test.py
tfx/dsl/components/common/manual_node.py
tfx/dsl/components/common/manual_node_test.py
tfx/dsl/components/common/resolver.py
tfx/dsl/components/common/resolver_test.py
tfx/dsl/context_managers/dsl_context.py
tfx/dsl/context_managers/dsl_context_manager.py
tfx/dsl/context_managers/dsl_context_manager_test.py
tfx/dsl/context_managers/dsl_context_registry.py
tfx/dsl/context_managers/dsl_context_registry_test.py
tfx/dsl/context_managers/test_utils.py
tfx/dsl/control_flow/for_each.py
tfx/dsl/control_flow/for_each_internal.py
tfx/dsl/control_flow/for_each_test.py
tfx/dsl/experimental/__init__.py
tfx/dsl/experimental/latest_artifacts_resolver.py
tfx/dsl/experimental/latest_blessed_model_resolver.py
tfx/dsl/experimental/spans_resolver.py
tfx/dsl/experimental/conditionals/__init__.py
tfx/dsl/experimental/conditionals/conditional.py
tfx/dsl/experimental/conditionals/conditional_test.py
tfx/dsl/experimental/node_execution_options/__init__.py
tfx/dsl/experimental/node_execution_options/utils.py
tfx/dsl/experimental/node_execution_options/utils_test.py
tfx/dsl/input_resolution/__init__.py
tfx/dsl/input_resolution/canned_resolver_functions.py
tfx/dsl/input_resolution/canned_resolver_functions_test.py
tfx/dsl/input_resolution/resolver_function.py
tfx/dsl/input_resolution/resolver_function_test.py
tfx/dsl/input_resolution/resolver_op.py
tfx/dsl/input_resolution/resolver_op_test.py
tfx/dsl/input_resolution/ops/all_spans_op.py
tfx/dsl/input_resolution/ops/all_spans_op_test.py
tfx/dsl/input_resolution/ops/consecutive_spans_op.py
tfx/dsl/input_resolution/ops/consecutive_spans_op_test.py
tfx/dsl/input_resolution/ops/equal_property_values_op.py
tfx/dsl/input_resolution/ops/equal_property_values_op_test.py
tfx/dsl/input_resolution/ops/exclude_spans_op.py
tfx/dsl/input_resolution/ops/exclude_spans_op_test.py
tfx/dsl/input_resolution/ops/graph_traversal_op.py
tfx/dsl/input_resolution/ops/graph_traversal_op_test.py
tfx/dsl/input_resolution/ops/group_by_lineage_op.py
tfx/dsl/input_resolution/ops/group_by_lineage_op_test.py
tfx/dsl/input_resolution/ops/latest_create_time_op.py
tfx/dsl/input_resolution/ops/latest_create_time_op_test.py
tfx/dsl/input_resolution/ops/latest_pipeline_run_outputs_op.py
tfx/dsl/input_resolution/ops/latest_pipeline_run_outputs_op_test.py
tfx/dsl/input_resolution/ops/latest_policy_model_op.py
tfx/dsl/input_resolution/ops/latest_policy_model_op_test.py
tfx/dsl/input_resolution/ops/latest_span_op.py
tfx/dsl/input_resolution/ops/latest_span_op_test.py
tfx/dsl/input_resolution/ops/latest_version_op.py
tfx/dsl/input_resolution/ops/latest_version_op_test.py
tfx/dsl/input_resolution/ops/ops.py
tfx/dsl/input_resolution/ops/ops_utils.py
tfx/dsl/input_resolution/ops/paired_spans_op.py
tfx/dsl/input_resolution/ops/paired_spans_op_test.py
tfx/dsl/input_resolution/ops/shuffle_op.py
tfx/dsl/input_resolution/ops/shuffle_op_test.py
tfx/dsl/input_resolution/ops/siblings_op.py
tfx/dsl/input_resolution/ops/siblings_op_test.py
tfx/dsl/input_resolution/ops/skip_if_empty_op.py
tfx/dsl/input_resolution/ops/skip_if_empty_op_test.py
tfx/dsl/input_resolution/ops/skip_if_less_than_n_spans_op.py
tfx/dsl/input_resolution/ops/skip_if_less_than_n_spans_op_test.py
tfx/dsl/input_resolution/ops/slice_op.py
tfx/dsl/input_resolution/ops/slice_op_test.py
tfx/dsl/input_resolution/ops/sliding_window_op.py
tfx/dsl/input_resolution/ops/sliding_window_op_test.py
tfx/dsl/input_resolution/ops/span_driven_evaluator_inputs_op.py
tfx/dsl/input_resolution/ops/span_driven_evaluator_inputs_op_test.py
tfx/dsl/input_resolution/ops/static_span_range_op.py
tfx/dsl/input_resolution/ops/static_span_range_op_test.py
tfx/dsl/input_resolution/ops/test_utils.py
tfx/dsl/input_resolution/ops/training_range_op.py
tfx/dsl/input_resolution/ops/training_range_op_test.py
tfx/dsl/input_resolution/ops/unnest_op.py
tfx/dsl/input_resolution/ops/unnest_op_test.py
tfx/dsl/input_resolution/strategies/__init__.py
tfx/dsl/input_resolution/strategies/conditional_strategy.py
tfx/dsl/input_resolution/strategies/conditional_strategy_test.py
tfx/dsl/input_resolution/strategies/latest_artifact_strategy.py
tfx/dsl/input_resolution/strategies/latest_artifact_strategy_test.py
tfx/dsl/input_resolution/strategies/latest_blessed_model_strategy.py
tfx/dsl/input_resolution/strategies/latest_blessed_model_strategy_test.py
tfx/dsl/input_resolution/strategies/span_range_strategy.py
tfx/dsl/input_resolution/strategies/span_range_strategy_test.py
tfx/dsl/io/__init__.py
tfx/dsl/io/fileio.py
tfx/dsl/io/filesystem.py
tfx/dsl/io/filesystem_registry.py
tfx/dsl/io/filesystem_registry_test.py
tfx/dsl/io/plugins/__init__.py
tfx/dsl/io/plugins/local.py
tfx/dsl/io/plugins/local_test.py
tfx/dsl/io/plugins/tensorflow_gfile.py
tfx/dsl/io/plugins/tensorflow_gfile_test.py
tfx/dsl/placeholder/__init__.py
tfx/dsl/placeholder/artifact_placeholder.py
tfx/dsl/placeholder/placeholder.py
tfx/dsl/placeholder/placeholder_base.py
tfx/dsl/placeholder/placeholder_test.py
tfx/dsl/placeholder/placeholder_test_util.py
tfx/dsl/placeholder/proto_placeholder.py
tfx/dsl/placeholder/proto_placeholder_test.py
tfx/dsl/placeholder/runtime_placeholders.py
tfx/dsl/resolvers/__init__.py
tfx/examples/chicago_taxi_pipeline/data/README.md
tfx/examples/chicago_taxi_pipeline/data/big_tipper_label/data.csv
tfx/examples/chicago_taxi_pipeline/data/simple/data.csv
tfx/examples/chicago_taxi_pipeline/data/user_provided_schema/schema.pbtxt
tfx/examples/imdb/data/imdb_small_with_labels.txt
tfx/experimental/templates/taxi/.gitignore
tfx/experimental/templates/taxi/data_validation.ipynb
tfx/experimental/templates/taxi/model_analysis.ipynb
tfx/orchestration/data_types.py
tfx/orchestration/data_types_test.py
tfx/orchestration/data_types_utils.py
tfx/orchestration/data_types_utils_test.py
tfx/orchestration/metadata.py
tfx/orchestration/metadata_test.py
tfx/orchestration/metadata_test_utils.py
tfx/orchestration/mlmd_connection_manager.py
tfx/orchestration/mlmd_connection_manager_test.py
tfx/orchestration/node_proto_view.py
tfx/orchestration/pipeline.py
tfx/orchestration/pipeline_test.py
tfx/orchestration/publisher.py
tfx/orchestration/publisher_test.py
tfx/orchestration/test_utils.py
tfx/orchestration/tfx_runner.py
tfx/orchestration/beam/testdata/pipeline_for_beam_dag_runner_test.pbtxt
tfx/orchestration/config/__init__.py
tfx/orchestration/config/base_component_config.py
tfx/orchestration/config/config_utils.py
tfx/orchestration/config/config_utils_test.py
tfx/orchestration/config/docker_component_config.py
tfx/orchestration/config/docker_component_config_test.py
tfx/orchestration/config/kubernetes_component_config.py
tfx/orchestration/config/pipeline_config.py
tfx/orchestration/config/pipeline_config_test.py
tfx/orchestration/experimental/interactive/export_templates/export_airflow.tmpl
tfx/orchestration/experimental/interactive/export_templates/export_beam.tmpl
tfx/orchestration/kubeflow/v2/artifact_types/Artifact.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Boolean.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Dataset.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ExampleAnomalies.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ExampleStatistics.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Examples.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ExamplesDiff.yaml
tfx/orchestration/kubeflow/v2/artifact_types/File.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Float.yaml
tfx/orchestration/kubeflow/v2/artifact_types/HyperParameters.yaml
tfx/orchestration/kubeflow/v2/artifact_types/InferenceResult.yaml
tfx/orchestration/kubeflow/v2/artifact_types/InfraBlessing.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Integer.yaml
tfx/orchestration/kubeflow/v2/artifact_types/JsonValue.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Metrics.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Model.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ModelBlessing.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ModelEvaluation.yaml
tfx/orchestration/kubeflow/v2/artifact_types/ModelRun.yaml
tfx/orchestration/kubeflow/v2/artifact_types/PushedModel.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Schema.yaml
tfx/orchestration/kubeflow/v2/artifact_types/Statistics.yaml
tfx/orchestration/kubeflow/v2/artifact_types/String.yaml
tfx/orchestration/kubeflow/v2/artifact_types/TransformCache.yaml
tfx/orchestration/kubeflow/v2/artifact_types/TransformGraph.yaml
tfx/orchestration/kubeflow/v2/artifact_types/TunerResults.yaml
tfx/orchestration/kubeflow/v2/container/testdata/artifacts.json
tfx/orchestration/kubeflow/v2/container/testdata/artifacts_legacy.json
tfx/orchestration/kubeflow/v2/container/testdata/exec_properties.json
tfx/orchestration/kubeflow/v2/container/testdata/executor_invocation.json
tfx/orchestration/kubeflow/v2/container/testdata/executor_invocation_legacy.json
tfx/orchestration/kubeflow/v2/container/testdata/executor_invocation_with_output_parameters.json
tfx/orchestration/kubeflow/v2/container/testdata/expected_output_metadata.json
tfx/orchestration/kubeflow/v2/testdata/expected_bq_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_bq_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_bq_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_consume_primitive_artifacts_by_value_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_csv_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_csv_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_csv_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_consumer_with_condition_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_consumer_with_condition_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_consumer_with_condition_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_container_spec_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_container_spec_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_container_spec_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_exit_handler_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_exit_handler_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dummy_exit_handler_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dynamic_execution_properties_downstream_component_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_dynamic_execution_properties_upstream_component_spec.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_full_taxi_pipeline_job.json
tfx/orchestration/kubeflow/v2/testdata/expected_import_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_import_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_import_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_component_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_executor_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_importer_task_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_artifact_resolver_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_artifact_resolver_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_artifact_resolver_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_blessed_model_resolver_component_1.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_blessed_model_resolver_component_2.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_blessed_model_resolver_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_blessed_model_resolver_task_1.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_latest_blessed_model_resolver_task_2.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_pipeline_with_one_container_spec_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_pipeline_with_runtime_parameter.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_pipeline_with_two_container_spec_components.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_kubeflow_artifacts_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_job.json
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_job_with_multiple_images.json
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_job_without_default_image.json
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_with_cache_enabled.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_with_dynamic_execution_properties.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_with_exit_handler.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_with_multiple_images.pbtxt
tfx/orchestration/kubeflow/v2/testdata/expected_two_step_pipeline_with_task_only_dependency.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_bq_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_bq_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_bq_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_consume_primitive_artifacts_by_value_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_csv_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_csv_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_csv_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_consumer_with_condition_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_consumer_with_condition_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_consumer_with_condition_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_container_spec_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_container_spec_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_container_spec_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_exit_handler_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_exit_handler_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dummy_exit_handler_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dynamic_execution_properties_downstream_component_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_dynamic_execution_properties_upstream_component_spec.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_full_taxi_pipeline_job.json
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_import_example_gen_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_import_example_gen_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_import_example_gen_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_component_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_executor_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_importer_task_with_runtime_param.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_artifact_resolver_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_artifact_resolver_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_artifact_resolver_task.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_blessed_model_resolver_component_1.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_blessed_model_resolver_component_2.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_blessed_model_resolver_executor.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_blessed_model_resolver_task_1.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_latest_blessed_model_resolver_task_2.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_pipeline_with_one_container_spec_component.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_pipeline_with_runtime_parameter.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_pipeline_with_two_container_spec_components.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_kubeflow_artifacts_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_job.json
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_job_with_multiple_images.json
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_job_without_default_image.json
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_with_cache_enabled.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_with_dynamic_execution_properties.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_with_exit_handler.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_with_multiple_images.pbtxt
tfx/orchestration/kubeflow/v2/testdata/legacy/expected_two_step_pipeline_with_task_only_dependency.pbtxt
tfx/orchestration/launcher/__init__.py
tfx/orchestration/launcher/base_component_launcher.py
tfx/orchestration/launcher/base_component_launcher_test.py
tfx/orchestration/launcher/container_common.py
tfx/orchestration/launcher/container_common_test.py
tfx/orchestration/launcher/docker_component_launcher.py
tfx/orchestration/launcher/docker_component_launcher_e2e_test.py
tfx/orchestration/launcher/docker_component_launcher_test.py
tfx/orchestration/launcher/in_process_component_launcher.py
tfx/orchestration/launcher/kubernetes_component_launcher.py
tfx/orchestration/launcher/kubernetes_component_launcher_test.py
tfx/orchestration/launcher/test_utils.py
tfx/orchestration/local/__init__.py
tfx/orchestration/local/local_dag_runner.py
tfx/orchestration/local/local_dag_runner_test.py
tfx/orchestration/local/local_pipeline_beam_test.py
tfx/orchestration/local/local_pipeline_test.py
tfx/orchestration/local/runner_utils.py
tfx/orchestration/local/legacy/__init__.py
tfx/orchestration/local/legacy/local_dag_runner.py
tfx/orchestration/local/legacy/local_dag_runner_test.py
tfx/orchestration/portable/__init__.py
tfx/orchestration/portable/base_driver.py
tfx/orchestration/portable/base_driver_operator.py
tfx/orchestration/portable/base_executor_operator.py
tfx/orchestration/portable/beam_executor_operator.py
tfx/orchestration/portable/beam_executor_operator_test.py
tfx/orchestration/portable/cache_utils.py
tfx/orchestration/portable/cache_utils_test.py
tfx/orchestration/portable/data_types.py
tfx/orchestration/portable/docker_executor_operator.py
tfx/orchestration/portable/docker_executor_operator_e2e_test.py
tfx/orchestration/portable/docker_executor_operator_test.py
tfx/orchestration/portable/execution_publish_utils.py
tfx/orchestration/portable/execution_publish_utils_test.py
tfx/orchestration/portable/execution_watcher.py
tfx/orchestration/portable/execution_watcher_test.py
tfx/orchestration/portable/importer_node_handler.py
tfx/orchestration/portable/importer_node_handler_test.py
tfx/orchestration/portable/inputs_utils.py
tfx/orchestration/portable/inputs_utils_test.py
tfx/orchestration/portable/kubernetes_executor_operator.py
tfx/orchestration/portable/kubernetes_executor_operator_test.py
tfx/orchestration/portable/launcher.py
tfx/orchestration/portable/launcher_test.py
tfx/orchestration/portable/merge_utils.py
tfx/orchestration/portable/merge_utils_test.py
tfx/orchestration/portable/outputs_utils.py
tfx/orchestration/portable/outputs_utils_test.py
tfx/orchestration/portable/partial_run_utils.py
tfx/orchestration/portable/partial_run_utils_test.py
tfx/orchestration/portable/python_driver_operator.py
tfx/orchestration/portable/python_driver_operator_test.py
tfx/orchestration/portable/python_executor_operator.py
tfx/orchestration/portable/python_executor_operator_test.py
tfx/orchestration/portable/resolver_node_handler.py
tfx/orchestration/portable/resolver_node_handler_test.py
tfx/orchestration/portable/runtime_parameter_utils.py
tfx/orchestration/portable/runtime_parameter_utils_test.py
tfx/orchestration/portable/system_node_handler.py
tfx/orchestration/portable/tfx_runner.py
tfx/orchestration/portable/execution/context.py
tfx/orchestration/portable/execution/di_providers.py
tfx/orchestration/portable/execution/di_providers_test.py
tfx/orchestration/portable/input_resolution/channel_resolver.py
tfx/orchestration/portable/input_resolution/channel_resolver_test.py
tfx/orchestration/portable/input_resolution/exceptions.py
tfx/orchestration/portable/input_resolution/input_graph_resolver.py
tfx/orchestration/portable/input_resolution/input_graph_resolver_test.py
tfx/orchestration/portable/input_resolution/node_inputs_resolver.py
tfx/orchestration/portable/input_resolution/node_inputs_resolver_test.py
tfx/orchestration/portable/input_resolution/partition_utils.py
tfx/orchestration/portable/input_resolution/partition_utils_test.py
tfx/orchestration/portable/input_resolution/mlmd_resolver/__init__.py
tfx/orchestration/portable/input_resolution/mlmd_resolver/metadata_resolver.py
tfx/orchestration/portable/input_resolution/mlmd_resolver/metadata_resolver_test.py
tfx/orchestration/portable/input_resolution/mlmd_resolver/metadata_resolver_utils.py
tfx/orchestration/portable/mlmd/__init__.py
tfx/orchestration/portable/mlmd/artifact_lib.py
tfx/orchestration/portable/mlmd/artifact_lib_test.py
tfx/orchestration/portable/mlmd/common_utils.py
tfx/orchestration/portable/mlmd/common_utils_test.py
tfx/orchestration/portable/mlmd/context_lib.py
tfx/orchestration/portable/mlmd/context_lib_test.py
tfx/orchestration/portable/mlmd/event_lib.py
tfx/orchestration/portable/mlmd/event_lib_test.py
tfx/orchestration/portable/mlmd/execution_lib.py
tfx/orchestration/portable/mlmd/execution_lib_test.py
tfx/orchestration/portable/mlmd/filter_query_builder.py
tfx/orchestration/portable/mlmd/store_ext.py
tfx/orchestration/portable/mlmd/store_ext_test.py
tfx/orchestration/portable/testdata/__init__.py
tfx/proto/bulk_inferrer.proto
tfx/proto/distribution_validator.proto
tfx/proto/evaluator.proto
tfx/proto/example_diff.proto
tfx/proto/example_gen.proto
tfx/proto/infra_validator.proto
tfx/proto/pusher.proto
tfx/proto/range_config.proto
tfx/proto/trainer.proto
tfx/proto/transform.proto
tfx/proto/tuner.proto
tfx/proto/orchestration/__init__.py
tfx/types/__init__.py
tfx/types/artifact.py
tfx/types/artifact_property.py
tfx/types/artifact_test.py
tfx/types/artifact_utils.py
tfx/types/artifact_utils_test.py
tfx/types/channel.py
tfx/types/channel_test.py
tfx/types/channel_utils.py
tfx/types/channel_utils_test.py
tfx/types/channel_wrapped_placeholder_test.py
tfx/types/component_spec.py
tfx/types/component_spec_test.py
tfx/types/external_artifact_utils.py
tfx/types/node_common.py
tfx/types/resolved_channel.py
tfx/types/standard_artifact_utils.py
tfx/types/standard_artifact_utils_test.py
tfx/types/standard_artifacts.py
tfx/types/standard_artifacts_test.py
tfx/types/standard_component_specs.py
tfx/types/system_artifacts.py
tfx/types/system_executions.py
tfx/types/value_artifact.py
tfx/types/value_artifact_test.py
tfx/types/experimental/__init__.py
tfx/types/experimental/simple_artifacts.py
tfx/utils/__init__.py
tfx/utils/abc_utils.py
tfx/utils/channel.py
tfx/utils/channel_test.py
tfx/utils/dependency_utils.py
tfx/utils/dependency_utils_test.py
tfx/utils/deprecation_utils.py
tfx/utils/deprecation_utils_test.py
tfx/utils/doc_controls.py
tfx/utils/doc_controls_test.py
tfx/utils/docker_utils.py
tfx/utils/docker_utils_test.py
tfx/utils/golden_utils.py
tfx/utils/governance_utils.py
tfx/utils/import_utils.py
tfx/utils/import_utils_test.py
tfx/utils/io_utils.py
tfx/utils/io_utils_test.py
tfx/utils/json_utils.py
tfx/utils/json_utils_test.py
tfx/utils/kube_utils.py
tfx/utils/logging_utils.py
tfx/utils/logging_utils_test.py
tfx/utils/metrics_utils.py
tfx/utils/monitoring_utils.py
tfx/utils/name_utils.py
tfx/utils/name_utils_test.py
tfx/utils/path_constants.py
tfx/utils/path_utils.py
tfx/utils/path_utils_test.py
tfx/utils/proto_utils.py
tfx/utils/proto_utils_test.py
tfx/utils/pure_typing_utils.py
tfx/utils/pure_typing_utils_test.py
tfx/utils/retry.py
tfx/utils/retry_test.py
tfx/utils/stats_utils.py
tfx/utils/status.py
tfx/utils/telemetry_utils.py
tfx/utils/telemetry_utils_test.py
tfx/utils/test_case_utils.py
tfx/utils/test_case_utils_test.py
tfx/utils/topsort.py
tfx/utils/topsort_test.py
tfx/utils/typing_utils.py
tfx/utils/typing_utils_test.py
tfx/utils/version_utils.py
tfx/utils/version_utils_test.py
tfx/utils/writer_utils.py
tfx/utils/writer_utils_test.py
tfx/utils/di/errors.py
tfx/utils/di/module.py
tfx/utils/di/module_test.py
tfx/utils/di/providers.py
tfx/utils/model_paths/__init__.py
tfx/utils/model_paths/tf_serving_flavor.py
tfx/utils/model_paths/tf_serving_flavor_test.py
tfx/utils/testdata/__init__.py
tfx/utils/testdata/test_fn.py