beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From tvalen...@apache.org
Subject [beam] branch master updated (f8da690 -> 648f6ac)
Date Tue, 09 Mar 2021 23:25:05 GMT
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(-)


Mime
View raw message