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 0389f54 Merge pull request #11173 [BEAM-9558] Add explicit end bit
for data channel.
add 56c15b9 Merge pull request #11153 from [BEAM-9537] Adding a new
module for FnApiRunner
No new revisions were added by this update.
Summary of changes:
sdks/python/apache_beam/pipeline.py | 6 +-
.../runners/dataflow/dataflow_runner.py | 9 +--
.../portability/fn_api_runner}/__init__.py | 1 +
.../fn_runner.py} | 69 +++++++++++-----------
.../fn_runner_test.py} | 13 ++--
.../translations.py} | 0
.../runners/portability/local_job_service.py | 10 ++--
.../runners/portability/portable_runner.py | 30 +++++-----
.../runners/portability/portable_runner_test.py | 4 +-
9 files changed, 74 insertions(+), 68 deletions(-)
copy sdks/python/apache_beam/{examples =>
runners/portability/fn_api_runner}/__init__.py (91%)
rename sdks/python/apache_beam/runners/portability/{fn_api_runner.py =>
fn_api_runner/fn_runner.py} (97%)
rename sdks/python/apache_beam/runners/portability/{fn_api_runner_test.py =>
fn_api_runner/fn_runner_test.py} (99%)
rename
sdks/python/apache_beam/runners/portability/{fn_api_runner_transforms.py =>
fn_api_runner/translations.py} (100%)
