This is an automated email from the ASF dual-hosted git repository. pabloem pushed a change to branch master in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1386b94 Merge pull request #10124: [BEAM-8670] Manage environment parallelism in DefaultJobBundleFactory add 49d6efd [BEAM-8661] Moving runners to have per-module logger (#10097) No new revisions were added by this update. Summary of changes: ...dataflow_exercise_streaming_metrics_pipeline.py | 4 ++- ...low_exercise_streaming_metrics_pipeline_test.py | 6 ++-- .../runners/dataflow/dataflow_metrics.py | 6 ++-- .../runners/dataflow/dataflow_runner.py | 19 +++++++----- .../runners/dataflow/internal/apiclient.py | 26 ++++++++-------- .../runners/dataflow/native_io/iobase.py | 4 ++- .../runners/dataflow/test_dataflow_runner.py | 4 ++- .../apache_beam/runners/direct/direct_runner.py | 7 +++-- sdks/python/apache_beam/runners/direct/executor.py | 10 ++++--- .../runners/direct/transform_evaluator.py | 4 ++- .../runners/interactive/interactive_environment.py | 11 ++++--- .../runners/interactive/interactive_runner.py | 9 ++++-- sdks/python/apache_beam/runners/job/manager.py | 4 ++- .../runners/portability/abstract_job_service.py | 8 +++-- .../runners/portability/expansion_service_test.py | 6 ++-- .../runners/portability/flink_runner.py | 4 ++- .../runners/portability/flink_runner_test.py | 7 +++-- .../portability/flink_uber_jar_job_server.py | 8 +++-- .../runners/portability/fn_api_runner.py | 32 ++++++++++---------- .../runners/portability/fn_api_runner_test.py | 4 ++- .../portability/fn_api_runner_transforms.py | 8 +++-- .../runners/portability/local_job_service.py | 12 ++++---- .../runners/portability/local_job_service_main.py | 4 ++- .../runners/portability/portable_metrics.py | 4 ++- .../runners/portability/portable_runner.py | 8 +++-- .../runners/portability/portable_runner_test.py | 8 +++-- .../apache_beam/runners/portability/stager.py | 35 ++++++++++++---------- .../apache_beam/runners/portability/stager_test.py | 8 +++-- sdks/python/apache_beam/runners/runner.py | 6 ++-- .../apache_beam/runners/worker/bundle_processor.py | 12 ++++---- .../apache_beam/runners/worker/data_plane.py | 9 +++--- .../apache_beam/runners/worker/log_handler_test.py | 8 +++-- .../apache_beam/runners/worker/operations.py | 13 ++++---- .../apache_beam/runners/worker/sdk_worker.py | 32 ++++++++++---------- .../apache_beam/runners/worker/sdk_worker_main.py | 22 +++++++------- .../apache_beam/runners/worker/sdk_worker_test.py | 8 +++-- .../apache_beam/runners/worker/sideinputs.py | 5 +++- .../apache_beam/runners/worker/statecache.py | 4 ++- .../runners/worker/statesampler_test.py | 6 ++-- .../apache_beam/runners/worker/worker_pool_main.py | 8 +++-- 40 files changed, 245 insertions(+), 158 deletions(-)