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 e42027b delint go sdk (#17247)
add 8a7c92c Merge pull request #16841 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/examples/matrix_power.py | 103 +++++
...ount_debugging_test.py => matrix_power_test.py} | 53 ++-
sdks/python/apache_beam/io/iobase.py | 12 +-
.../runners/portability/fn_api_runner/execution.py | 359 ++++++++++++----
.../runners/portability/fn_api_runner/fn_runner.py | 473 ++++++++++++++-------
.../portability/fn_api_runner/fn_runner_test.py | 24 +-
.../portability/fn_api_runner/translations.py | 69 ++-
.../fn_api_runner/visualization_tools.py | 30 +-
.../portability/fn_api_runner/watermark_manager.py | 53 ++-
.../portability/fn_api_runner/worker_handlers.py | 3 +
.../apache_beam/transforms/userstate_test.py | 40 ++
sdks/python/apache_beam/transforms/util.py | 3 +
12 files changed, 945 insertions(+), 277 deletions(-)
create mode 100644 sdks/python/apache_beam/examples/matrix_power.py
copy sdks/python/apache_beam/examples/{wordcount_debugging_test.py =>
matrix_power_test.py} (50%)
