This is an automated email from the ASF dual-hosted git repository.
lcwik pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 45d8a28191a686493534acb3588bbd7e9c3d3139
Merge: 3d576f7 f391aa4
Author: Lukasz Cwik <lukec...@gmail.com>
AuthorDate: Mon Jul 1 12:28:18 2019 -0700
[BEAM-3645] add ParallelBundleManager
.../python/apache_beam/options/pipeline_options.py | 5 +
.../apache_beam/options/pipeline_options_test.py | 6 +
.../runners/portability/fn_api_runner.py | 125 ++++++++++++++++-----
.../runners/portability/fn_api_runner_test.py | 46 +++++++-
.../apache_beam/runners/worker/data_plane.py | 2 +-
5 files changed, 154 insertions(+), 30 deletions(-)
