This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from 96e79cba3a6 Concat protos in BQStorageWriteAPI - solve edge cases
during mering of nested repeated fields (#34436)
add 19fef1bba24 add changes comment on yaml output_schema (#36497)
add 57e34b6906b Fix proto map access. (#36532)
add faae168fa34 Bump github.com/aws/smithy-go from 1.23.0 to 1.23.1 in
/sdks (#36533)
add 118b3c7a582 PortableRunner tests: surface worker-thread exceptions on
main thread after wait_until_finish() (fixes #35211) (#36485)
add 5d420c5f047 Add pickler.roundtrip() shortcut for testing pickle
(#36441)
add 2b43f8018ba Pin specifiable test to FnApiRunner (#36536)
add f07ccf37cbe Track bundle processors that are pending creation and
terminate SDK if creating a BP exceeds a timeout. (#36518)
add 581ec8bb17f Always mark the instruction as cleaned up in the GRPC data
channel when processing an instruction fails. (#36367)
add e87f8097e53 Move setup/teardown to class level to avoid flakiness
(#36546)
add 6ffc68778b9 Fix build release candidate workflow (#36541)
add d91fb6d6987 Timeout execution tree creation for SDK worker ops.
(#36200)
add d4dc3243303 Fix dill tox (#36543)
add 34a6f542a7f Update beam_PreCommit_Python_ML.yml (#36550)
No new revisions were added by this update.
Summary of changes:
.../trigger_files/beam_PreCommit_Python_Dill.json | 2 +-
.github/workflows/beam_PreCommit_Python_ML.yml | 12 +++
.github/workflows/build_release_candidate.yml | 19 ++--
.../republish_released_docker_containers.yml | 3 +-
CHANGES.md | 1 +
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
...xpansionServiceSchemaTransformProviderTest.java | 2 +-
.../apache_beam/internal/cloudpickle_pickler.py | 46 +++++---
sdks/python/apache_beam/internal/dill_pickler.py | 42 +++++---
sdks/python/apache_beam/internal/pickler.py | 5 +
sdks/python/apache_beam/io/filebasedsource.py | 4 +-
.../runners/direct/transform_evaluator.py | 2 +-
.../runners/portability/local_job_service.py | 1 -
.../runners/portability/portable_runner.py | 14 ++-
.../apache_beam/runners/worker/bundle_processor.py | 27 ++++-
.../apache_beam/runners/worker/data_plane.py | 19 +++-
.../apache_beam/runners/worker/sdk_worker.py | 19 ++--
.../apache_beam/runners/worker/sdk_worker_main.py | 4 +
.../apache_beam/runners/worker/sdk_worker_test.py | 44 +++++++-
.../apache_beam/runners/worker/worker_status.py | 118 ++++++++++++++++-----
.../runners/worker/worker_status_test.py | 96 ++++++++++++++++-
sdks/python/apache_beam/transforms/core.py | 4 +-
sdks/python/apache_beam/transforms/core_it_test.py | 36 ++++---
sdks/python/apache_beam/transforms/ptransform.py | 6 +-
sdks/python/apache_beam/transforms/util_test.py | 36 ++++---
.../transforms/validate_runner_xlang_test.py | 36 ++++---
.../apache_beam/yaml/yaml_specifiable_test.py | 7 +-
sdks/python/tox.ini | 2 +-
29 files changed, 461 insertions(+), 152 deletions(-)
