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%)