[beam] branch master updated (455dd10 -> 2aab1b0)

[tv...@apache.org]

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 455dd10  Merge pull request #14580 from [BEAM-12192] Have WatchKafkaTopicPartitionDoFn respects topics given by KafkaIO
     add 51541a5  [BEAM-7372] cleanup py2 codepath from apache_beam/runners/direct, job, portability and test * usage of future package * usage of past package * unnecessary builtins import
     add 2aab1b0  [BEAM-7372] cleanup py2 codepaths in apache_beam/runners/direct, job, portability and test #14565

No new revisions were added by this update.

Summary of changes:
 sdks/python/apache_beam/runners/direct/__init__.py        |  1 -
 sdks/python/apache_beam/runners/direct/bundle_factory.py  |  3 ---
 sdks/python/apache_beam/runners/direct/clock.py           |  3 ---
 .../runners/direct/consumer_tracking_pipeline_visitor.py  |  2 --
 .../direct/consumer_tracking_pipeline_visitor_test.py     |  2 --
 sdks/python/apache_beam/runners/direct/direct_metrics.py  |  3 ---
 .../apache_beam/runners/direct/direct_metrics_test.py     |  2 --
 sdks/python/apache_beam/runners/direct/direct_runner.py   |  2 --
 .../apache_beam/runners/direct/direct_runner_test.py      |  2 --
 .../python/apache_beam/runners/direct/direct_userstate.py |  2 --
 .../apache_beam/runners/direct/evaluation_context.py      |  3 ---
 sdks/python/apache_beam/runners/direct/executor.py        | 10 ++--------
 .../apache_beam/runners/direct/helper_transforms.py       |  2 --
 .../apache_beam/runners/direct/sdf_direct_runner.py       |  3 ---
 .../apache_beam/runners/direct/sdf_direct_runner_test.py  |  4 ----
 .../apache_beam/runners/direct/test_direct_runner.py      |  3 ---
 .../python/apache_beam/runners/direct/test_stream_impl.py |  3 ---
 .../apache_beam/runners/direct/transform_evaluator.py     |  7 +------
 sdks/python/apache_beam/runners/direct/util.py            |  4 ----
 .../apache_beam/runners/direct/watermark_manager.py       |  3 ---
 sdks/python/apache_beam/runners/job/__init__.py           |  1 -
 sdks/python/apache_beam/runners/job/manager.py            |  3 ---
 sdks/python/apache_beam/runners/job/utils.py              |  2 --
 sdks/python/apache_beam/runners/portability/__init__.py   |  2 --
 .../runners/portability/abstract_job_service.py           |  3 ---
 .../apache_beam/runners/portability/artifact_service.py   |  6 +-----
 .../runners/portability/artifact_service_test.py          |  7 +------
 .../apache_beam/runners/portability/expansion_service.py  |  3 ---
 .../runners/portability/expansion_service_test.py         | 15 ++++++---------
 .../apache_beam/runners/portability/flink_runner.py       |  3 ---
 .../apache_beam/runners/portability/flink_runner_test.py  |  6 +-----
 .../runners/portability/flink_uber_jar_job_server.py      |  3 ---
 .../runners/portability/flink_uber_jar_job_server_test.py |  3 ---
 .../runners/portability/fn_api_runner/__init__.py         |  1 -
 .../runners/portability/fn_api_runner/execution.py        |  2 --
 .../runners/portability/fn_api_runner/fn_runner.py        |  4 ----
 .../runners/portability/fn_api_runner/fn_runner_test.py   |  4 ----
 .../runners/portability/fn_api_runner/translations.py     |  8 +-------
 .../portability/fn_api_runner/translations_test.py        |  2 --
 .../runners/portability/fn_api_runner/worker_handlers.py  |  3 ---
 sdks/python/apache_beam/runners/portability/job_server.py |  2 --
 .../apache_beam/runners/portability/job_server_test.py    |  3 ---
 .../apache_beam/runners/portability/local_job_service.py  |  3 ---
 .../runners/portability/local_job_service_main.py         |  3 ---
 .../runners/portability/local_job_service_test.py         |  3 ---
 .../apache_beam/runners/portability/portable_metrics.py   |  2 --
 .../apache_beam/runners/portability/portable_runner.py    |  3 ---
 .../runners/portability/portable_runner_test.py           |  3 ---
 .../runners/portability/sdk_container_builder.py          |  2 --
 .../runners/portability/sdk_container_builder_test.py     |  2 --
 .../apache_beam/runners/portability/spark_runner.py       |  3 ---
 .../apache_beam/runners/portability/spark_runner_test.py  |  3 ---
 .../runners/portability/spark_uber_jar_job_server.py      |  3 ---
 .../runners/portability/spark_uber_jar_job_server_test.py |  3 ---
 sdks/python/apache_beam/runners/portability/stager.py     |  4 +---
 .../python/apache_beam/runners/portability/stager_test.py |  2 --
 sdks/python/apache_beam/runners/test/__init__.py          |  2 --
 57 files changed, 14 insertions(+), 177 deletions(-)