You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by pa...@apache.org on 2021/10/12 03:01:18 UTC
[beam] branch master updated (c8e7a4c -> ef43645)
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 c8e7a4c Release 2.33 documentation update (#15543)
add ef43645 Merge pull request #15441 from [BEAM-8823] Make FnApiRunner work by executing ready elements instead of stages
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/io/iobase.py | 12 +-
.../runners/portability/fn_api_runner/execution.py | 357 +++++++++++++----
.../runners/portability/fn_api_runner/fn_runner.py | 442 ++++++++++++++-------
.../portability/fn_api_runner/fn_runner_test.py | 5 +
.../portability/fn_api_runner/translations.py | 37 +-
.../portability/fn_api_runner/watermark_manager.py | 15 +-
.../portability/fn_api_runner/worker_handlers.py | 3 +
sdks/python/apache_beam/transforms/util.py | 3 +
8 files changed, 645 insertions(+), 229 deletions(-)