This is an automated email from the ASF dual-hosted git repository.
github-actions[bot] pushed a change to branch nightly-refs/heads/master
in repository https://gitbox.apache.org/repos/asf/beam.git
from f9b15b711ae Refactor Java Secret classes to align with Python SDK
(#39806)
add e7aad65cf0e Bump github.com/moby/go-archive from 0.2.0 to 0.3.0 in
/sdks (#39810)
add 3889477e216 [GSoC-273] Fixing the github action Unmanaged Service
Account Keys (#39177)
add 6356a3c3d28 [Dataflow Streaming] Commit size validation for multi key
commits (#39473)
add b68a384657b Bump google.golang.org/protobuf from 1.36.11 to 1.36.12 in
/sdks (#39814)
add a99c2638cef Bump github.com/nats-io/nats-server/v2 from 2.14.4 to
2.14.5 in /sdks (#39813)
add 658397cde39 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#39812)
add d8935269847 Set getSession to synchronized to avoid race conditions
(#39817)
add 6a8eee94aa4 Bump ClassGraph from 4.8.162 to 4.8.192 (#39815)
add e4962bc90d9 [GSoC-273] Implement TestPubsubContext for Python GCP
Integration Tests (#39685)
add 94510075efe Update SKILLs based on review practice (#39805)
No new revisions were added by this update.
Summary of changes:
.agent/skills/beam-concepts/SKILL.md | 31 ++
.agent/skills/contributing/SKILL.md | 3 +
.github/workflows/README.md | 1 -
.../beam_Infrastructure_AuditUnmanagedKeys.yml | 76 ---
.../beam_Infrastructure_PolicyEnforcer.yml | 13 +-
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +-
infra/enforcement/README.md | 18 +-
infra/enforcement/account_keys.py | 76 ++-
infra/enforcement/iam.py | 83 +++-
infra/enforcement/sending.py | 57 ++-
.../worker/StreamingModeExecutionContext.java | 49 +-
.../streaming/BoundedQueueExecutorWorkHandle.java | 8 +-
.../dataflow/worker/streaming/ExecutableWork.java | 8 +
...java => MultiKeyCommitValidationException.java} | 12 +-
.../runners/dataflow/worker/streaming/Work.java | 20 +
.../dataflow/worker/util/BoundedQueueExecutor.java | 11 +-
.../dataflow/worker/util/KeyGroupWorkQueue.java | 12 +-
.../work/processing/StreamingWorkScheduler.java | 21 +-
.../processing/failures/WorkFailureProcessor.java | 11 +
.../worker/StreamingDataflowWorkerTest.java | 535 ++++++++++++++++++++-
.../worker/StreamingModeExecutionContextTest.java | 44 +-
.../worker/util/KeyGroupWorkQueueTest.java | 21 +
.../failures/WorkFailureProcessorTest.java | 23 +
sdks/go.mod | 12 +-
sdks/go.sum | 24 +-
.../beam/sdk/io/cassandra/ConnectionManager.java | 2 +-
.../apache_beam/io/gcp/pubsub_io_perf_test.py | 13 +-
.../apache_beam/testing/pubsub_test_context.py | 179 +++++++
.../testing/pubsub_test_context_test.py | 149 ++++++
29 files changed, 1287 insertions(+), 227 deletions(-)
delete mode 100644 .github/workflows/beam_Infrastructure_AuditUnmanagedKeys.yml
copy
runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/{FailedWorkHandler.java
=> MultiKeyCommitValidationException.java} (74%)
create mode 100644 sdks/python/apache_beam/testing/pubsub_test_context.py
create mode 100644 sdks/python/apache_beam/testing/pubsub_test_context_test.py
