This is an automated email from the ASF dual-hosted git repository.
robertwb pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from e852ac8 [BEAM-5600, BEAM-2939] Add SplittableParDo expansion logic to
runner's core.
add 090b510 [BEAM-8539] Make job state transitions in python-based
runners consistent with java-based runners (#9965)
No new revisions were added by this update.
Summary of changes:
.../src/main/proto/beam_job_api.proto | 23 ++++++++++++++++++++++
.../interactive/interactive_environment_test.py | 3 +--
.../runners/portability/abstract_job_service.py | 12 +++++------
.../portability/flink_uber_jar_job_server.py | 6 +++---
.../runners/portability/local_job_service.py | 10 ++++++----
.../runners/portability/portable_runner.py | 2 +-
sdks/python/apache_beam/runners/runner.py | 2 +-
.../apache_beam/testing/pipeline_verifiers_test.py | 3 +--
8 files changed, 41 insertions(+), 20 deletions(-)
