This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from d16f2a9 Bump python precommit timeout
add 33cc30e [BEAM-8151] Swap to create SdkWorkers on demand when
processing jobs
add 5de27d5 [BEAM-8151] Swap to create SdkWorkers on demand when
processing jobs
No new revisions were added by this update.
Summary of changes:
.../runners/portability/fn_api_runner.py | 8 +-
.../runners/portability/fn_api_runner_test.py | 12 +--
.../runners/portability/portable_runner.py | 1 -
.../apache_beam/runners/worker/sdk_worker.py | 103 ++++++---------------
.../apache_beam/runners/worker/sdk_worker_main.py | 30 ------
.../runners/worker/sdk_worker_main_test.py | 47 +---------
.../apache_beam/runners/worker/sdk_worker_test.py | 7 +-
.../apache_beam/runners/worker/worker_pool_main.py | 16 +---
sdks/python/apache_beam/transforms/environments.py | 24 ++---
.../apache_beam/transforms/environments_test.py | 9 +-
.../apache_beam/utils/thread_pool_executor_test.py | 8 ++
11 files changed, 55 insertions(+), 210 deletions(-)
