[pull] master from apache:master - #523
Merged
Merged
Conversation
Bumps [github.com/aws/aws-sdk-go-v2/service/s3](https://github.com/aws/aws-sdk-go-v2) from 1.104.2 to 1.105.0. - [Release notes](https://github.com/aws/aws-sdk-go-v2/releases) - [Commits](aws/aws-sdk-go-v2@service/s3/v1.104.2...service/s3/v1.105.0) --- updated-dependencies: - dependency-name: github.com/aws/aws-sdk-go-v2/service/s3 dependency-version: 1.105.0 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps [github.com/aws/aws-sdk-go-v2/config](https://github.com/aws/aws-sdk-go-v2) from 1.32.27 to 1.32.28. - [Release notes](https://github.com/aws/aws-sdk-go-v2/releases) - [Commits](aws/aws-sdk-go-v2@config/v1.32.27...config/v1.32.28) --- updated-dependencies: - dependency-name: github.com/aws/aws-sdk-go-v2/config dependency-version: 1.32.28 dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps [golang.org/x/text](https://github.com/golang/text) from 0.38.0 to 0.39.0. - [Release notes](https://github.com/golang/text/releases) - [Commits](golang/text@v0.38.0...v0.39.0) --- updated-dependencies: - dependency-name: golang.org/x/text dependency-version: 0.39.0 dependency-type: direct:production update-type: version-update:semver-minor ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
Bumps [github.com/aws/aws-sdk-go-v2/feature/s3/manager](https://github.com/aws/aws-sdk-go-v2) from 1.22.30 to 1.22.31. - [Release notes](https://github.com/aws/aws-sdk-go-v2/releases) - [Commits](aws/aws-sdk-go-v2@feature/s3/manager/v1.22.30...feature/s3/manager/v1.22.31) --- updated-dependencies: - dependency-name: github.com/aws/aws-sdk-go-v2/feature/s3/manager dependency-version: 1.22.31 dependency-type: direct:production update-type: version-update:semver-patch ... Signed-off-by: dependabot[bot] <support@github.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Derrick Williams <derrickaw@google.com>
EnvoyRateLimiter only needed a handful of protobuf message classes from envoy-data-plane, which pulls in the outdated betterproto==2.0.0b6 beta (a protobuf reimplementation) plus grpclib and transitive deps. That pin is the last blocker stopping Apache Airflow from un-suspending its Beam provider (apache/airflow#66952), and it forced a Python-version split in setup.py. The dependency was already fought rather than used: the RateLimitServiceStub bridge exists solely because betterproto emits async grpclib stubs that don't work with Beam's synchronous grpcio, and the wire is plain protobuf over grpcio regardless. Replace it with a minimal, self-contained rate_limit.proto compiled to a checked-in rate_limit_pb2.py (following the existing proto2_coder_test_messages_pb2.py precedent). Field numbers match Envoy's rls.proto/ratelimit.proto, so it stays wire-compatible with a real RLS server. This removes the conflict permanently for every downstream, deletes the py<3.11 split, and drops betterproto + grpclib from every container image. New wire-format tests pin the field numbers/enum values so a renumbering can't silently break live rate limiting (the mock-based tests would not). Note: the container base_image_requirements.txt files had the two direct packages removed to stay consistent with setup.py; a full `generatePythonRequirementsAll` regeneration should follow in CI to also prune now-orphaned transitives (grpclib, h2, multidict, ...) and refresh pins. Part of #37854 Unblocks apache/airflow#66952 Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>
* Add MLTransform embedding benchmarks * resolved code review comments * Refactor DataflowCostBenchmark worker interval and throughput helpers
…38971) The four timeout-related tests asserted the exact grouping of messages into SendMessageBatch calls. Those groupings depend on wall-clock timing (the per-message Thread.sleep delay racing the configured batch timeout), so on loaded CI runners batches form differently and the strict verify(...).sendMessageBatch(request(exact entries)) checks fail with Mockito ArgumentsAreDifferent. Rewrite the assertions to verify timing-independent invariants instead: all expected message bodies are sent exactly once, no batch exceeds the size implied by the timeout cadence, and at least the minimum number of batches is produced. This still exercises the timeout-driven flushing (both synchronous and the strict separate-thread variant) without depending on exact wall-clock behavior. Fixes #38946
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to subscribe to this conversation on GitHub.
Already have an account?
Sign in.
5 participants
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
See Commits and Changes for more details.
Created by
pull[bot] (v2.0.0-alpha.4)
Can you help keep this open source service alive? 💖 Please sponsor : )