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(-)
