This is an automated email from the ASF dual-hosted git repository.
tvalentyn pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d502185 [BEAM-12118] Modify QueuingBeamFnDataClient to avoid
completion latency due to polling. (#14480)
add 8bb55c6 [BEAM-7372] cleanup py2 codepath from apache_beam/testing
(#14496)
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/testing/__init__.py | 1 -
sdks/python/apache_beam/testing/benchmarks/__init__.py | 1 -
.../testing/benchmarks/chicago_taxi/preprocess.py | 2 --
.../testing/benchmarks/chicago_taxi/process_tfma.py | 2 --
.../apache_beam/testing/benchmarks/chicago_taxi/setup.py | 2 --
.../benchmarks/chicago_taxi/tfdv_analyze_and_validate.py | 4 ----
.../testing/benchmarks/chicago_taxi/trainer/model.py | 4 ----
.../testing/benchmarks/chicago_taxi/trainer/task.py | 4 ----
.../testing/benchmarks/chicago_taxi/trainer/taxi.py | 4 ----
.../apache_beam/testing/benchmarks/nexmark/__init__.py | 1 -
.../testing/benchmarks/nexmark/models/__init__.py | 1 -
.../testing/benchmarks/nexmark/models/auction_bid.py | 2 --
.../testing/benchmarks/nexmark/models/nexmark_model.py | 2 --
.../apache_beam/testing/benchmarks/nexmark/monitor.py | 2 --
.../testing/benchmarks/nexmark/nexmark_launcher.py | 4 ----
.../apache_beam/testing/benchmarks/nexmark/nexmark_util.py | 3 ---
.../benchmarks/nexmark/queries/nexmark_query_util.py | 2 --
.../testing/benchmarks/nexmark/queries/query0.py | 2 --
.../testing/benchmarks/nexmark/queries/query1.py | 2 --
.../testing/benchmarks/nexmark/queries/query10.py | 2 --
.../testing/benchmarks/nexmark/queries/query11.py | 2 --
.../testing/benchmarks/nexmark/queries/query12.py | 2 --
.../testing/benchmarks/nexmark/queries/query2.py | 2 --
.../testing/benchmarks/nexmark/queries/query3.py | 2 --
.../testing/benchmarks/nexmark/queries/query4.py | 2 --
.../testing/benchmarks/nexmark/queries/query5.py | 2 --
.../testing/benchmarks/nexmark/queries/query6.py | 3 ---
.../testing/benchmarks/nexmark/queries/query7.py | 2 --
.../testing/benchmarks/nexmark/queries/query8.py | 2 --
.../testing/benchmarks/nexmark/queries/query9.py | 2 --
.../testing/benchmarks/nexmark/queries/winning_bids.py | 2 --
sdks/python/apache_beam/testing/datatype_inference.py | 12 +-----------
sdks/python/apache_beam/testing/datatype_inference_test.py | 5 +----
sdks/python/apache_beam/testing/extra_assertions.py | 13 -------------
sdks/python/apache_beam/testing/extra_assertions_test.py | 2 --
.../apache_beam/testing/load_tests/co_group_by_key_test.py | 2 --
sdks/python/apache_beam/testing/load_tests/combine_test.py | 2 --
.../apache_beam/testing/load_tests/group_by_key_test.py | 2 --
sdks/python/apache_beam/testing/load_tests/load_test.py | 2 --
.../testing/load_tests/load_test_metrics_utils.py | 2 --
.../apache_beam/testing/load_tests/microbenchmarks_test.py | 2 --
sdks/python/apache_beam/testing/load_tests/pardo_test.py | 2 --
.../python/apache_beam/testing/load_tests/sideinput_test.py | 3 ---
sdks/python/apache_beam/testing/metric_result_matchers.py | 2 --
.../apache_beam/testing/metric_result_matchers_test.py | 2 --
sdks/python/apache_beam/testing/pipeline_verifiers.py | 2 --
sdks/python/apache_beam/testing/pipeline_verifiers_test.py | 3 ---
sdks/python/apache_beam/testing/synthetic_pipeline.py | 7 -------
sdks/python/apache_beam/testing/synthetic_pipeline_test.py | 2 --
sdks/python/apache_beam/testing/test_pipeline.py | 2 --
sdks/python/apache_beam/testing/test_pipeline_test.py | 2 --
sdks/python/apache_beam/testing/test_stream.py | 7 +------
sdks/python/apache_beam/testing/test_stream_it_test.py | 2 --
sdks/python/apache_beam/testing/test_stream_service.py | 2 --
sdks/python/apache_beam/testing/test_stream_service_test.py | 2 --
sdks/python/apache_beam/testing/test_stream_test.py | 2 --
sdks/python/apache_beam/testing/test_utils.py | 3 ---
sdks/python/apache_beam/testing/test_utils_test.py | 2 --
sdks/python/apache_beam/testing/util.py | 3 ---
sdks/python/apache_beam/testing/util_test.py | 8 --------
60 files changed, 3 insertions(+), 169 deletions(-)