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 f8da690 Merge pull request #14160 [BEAM-11357] Add the ability to
declare annotations to Python.
add 648f6ac [BEAM-7372][BEAM-9372] Cleanup py2 and py35 codepath from
runners (#14137)
No new revisions were added by this update.
Summary of changes:
.../runners/dataflow/dataflow_runner.py | 21 +--
.../runners/dataflow/dataflow_runner_test.py | 6 +-
.../runners/dataflow/internal/apiclient.py | 2 +-
.../runners/dataflow/internal/apiclient_test.py | 141 ++++++---------------
.../consumer_tracking_pipeline_visitor_test.py | 4 -
.../interactive/background_caching_job_test.py | 3 -
.../runners/interactive/cache_manager.py | 11 +-
.../runners/interactive/caching/streaming_cache.py | 12 +-
.../display/pcoll_visualization_test.py | 3 -
.../runners/interactive/interactive_beam_test.py | 18 ---
.../runners/interactive/interactive_environment.py | 8 +-
.../interactive/interactive_environment_test.py | 3 -
.../runners/interactive/interactive_runner_test.py | 3 -
.../interactive/options/capture_control_test.py | 3 -
.../runners/interactive/recording_manager_test.py | 25 ----
.../apache_beam/runners/interactive/utils_test.py | 7 -
.../runners/portability/artifact_service.py | 3 -
.../runners/portability/flink_runner.py | 5 -
.../portability/flink_uber_jar_job_server_test.py | 2 -
.../portability/fn_api_runner/fn_runner_test.py | 17 +--
.../runners/portability/spark_runner.py | 5 -
.../portability/spark_uber_jar_job_server_test.py | 2 -
.../apache_beam/runners/portability/stager.py | 4 +-
.../apache_beam/runners/portability/stager_test.py | 35 -----
.../apache_beam/runners/worker/operations.py | 6 +-
.../runners/worker/sdk_worker_main_test.py | 2 -
26 files changed, 57 insertions(+), 294 deletions(-)
