This is an automated email from the ASF dual-hosted git repository.
thw pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 098c11f Merge pull request #9392 from kamilwu/seed-job-from-local-git
add 9266887 [BEAM-7980] Containerized Python worker pool for external
environment
add 3561100 Merge pull request #9371: [BEAM-7980] External environment
with containerized worker pool
No new revisions were added by this update.
Summary of changes:
.../fn-execution/src/main/proto/beam_fn_api.proto | 18 ++-
.../environment/DockerEnvironmentFactory.java | 4 +-
.../environment/ExternalEnvironmentFactory.java | 40 ++++-
.../runners/reference/ExternalWorkerService.java | 11 +-
.../runners/portability/fn_api_runner.py | 4 +-
.../runners/portability/portable_runner.py | 60 +------
.../runners/portability/portable_runner_test.py | 3 +-
.../apache_beam/runners/worker/worker_pool_main.py | 177 +++++++++++++++++++++
sdks/python/container/boot.go | 13 ++
9 files changed, 251 insertions(+), 79 deletions(-)
create mode 100644 sdks/python/apache_beam/runners/worker/worker_pool_main.py
