You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by gi...@apache.org on 2025/08/26 04:04:55 UTC

(beam) branch nightly-refs/heads/master updated (d4d8fd8b626 -> f3d10e30d4f)

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 d4d8fd8b626 Update async_dofn.py (#35924)
     add 26ba4a733e1 [Java Dataflow Streaming] Fix IllegalStateException in WindmillSink by clearing Stream after coder exceptions (#31914) (#35942)
     add 1c2aa1c4689 Change schedule (#35950)
     add 245d5a5b504 Bump github.com/nats-io/nats.go from 1.43.0 to 1.45.0 in /sdks (#35927)
     add 5634b06846e Bump google.golang.org/protobuf from 1.36.7 to 1.36.8 in /sdks (#35937)
     add 47eb9dacb61 Add AftersynchronizedProcessing Time as continuation trigger in Python SDK (#35913)
     add f3d10e30d4f Infra enforcer gha (#35910)

No new revisions were added by this update.

Summary of changes:
 .../beam_Infrastructure_PolicyEnforcer.yml         |  83 ++++++++++++++
 ...ml => beam_Infrastructure_UsersPermissions.yml} |   0
 .../workflows/beam_StressTests_Java_KafkaIO.yml    |   2 +-
 infra/enforcement/README.md                        |  77 +++++++++++--
 infra/enforcement/config.yml                       |   5 +-
 infra/enforcement/requirements.txt                 |   1 +
 .../beam/runners/dataflow/worker/WindmillSink.java |   9 +-
 sdks/go.mod                                        |   4 +-
 sdks/go.sum                                        |   8 +-
 sdks/python/apache_beam/transforms/core.py         |  12 +++
 .../apache_beam/transforms/ptransform_test.py      |  19 ++++
 sdks/python/apache_beam/transforms/trigger.py      | 119 ++++++++++++++++++++-
 sdks/python/apache_beam/transforms/trigger_test.py |  50 +++++++++
 13 files changed, 365 insertions(+), 24 deletions(-)
 create mode 100644 .github/workflows/beam_Infrastructure_PolicyEnforcer.yml
 rename .github/workflows/{beam_UserRoles.yml => beam_Infrastructure_UsersPermissions.yml} (100%)