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 a9f808e4c45 [Python] Resolve AWS credentials through a secret manager
(`--aws_credentials_secret_manager`) (#40547)
add 56c3aa231b5 [OpenTelemetry] Spanner change streams otel configuration
cleanup (#40552)
add 0c95a398eb9 minor google ads version workflow changes (#40567)
add a7847a7bba3 Add Gemini Enterprise Agent Platform code review workflow
(#40561)
add 353ddaccf4c Update portability.md to remove Dataflow Runner v2
reference. (#40575)
add 852cb00876c Bump github.com/nats-io/nats-server/v2 from 2.15.0 to
2.15.1 in /sdks (#40582)
add 55f97af1fcf Bump github.com/aws/aws-sdk-go-v2 from 1.47.2 to 1.47.3 in
/sdks (#40584)
add 385668bb2b5 Bump golang.org/x/net from 0.59.0 to 0.61.0 in /sdks
(#40586)
add d97338e69ab Bump github.com/aws/aws-sdk-go-v2/credentials in /sdks
(#40585)
add c31bbe9e209 [Python] Catch PermissionDenied when checking the feature
store in VertexAIFeatureStoreEnrichmentHandler (#40463)
add 1d3bc627199 [Python] Keep the Series name in DataFrame Series.agg with
a list (#40573)
add e9aef3e124d Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#40583)
add 515b622c30f add a draft gemini review check (#40589)
add 3463d1efa9d Add opt-in lazy Dask side inputs with worker-safe
computation (#40496)
add f53cafc8956 Upgrade Google Ads to 47.0.0 (API v25) (#40566)
add 35ed6c70d80 Add YAML tests for writing to Iceberg CDC sink (#40542)
add 65ea034a6f1 Fix ModelManager tag mismatch on release after model
update (#40469) (#40473)
add 4a94900f5d4 [Python] Finish async bundles after processing outputs
(#40000)
add fbc9db6bae6 [Python] Return every group from Regex.all_matches (#40563)
No new revisions were added by this update.
Summary of changes:
.../beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.github/workflows/README.md | 2 +-
...ion.yml => beam_Upgrade_Google_Ads_Version.yml} | 8 +-
.github/workflows/dask_runner_tests.yml | 15 ++
.github/workflows/gemini_code_review.yml | 248 +++++++++++++++++++++
CHANGES.md | 3 +
sdks/go.mod | 52 ++---
sdks/go.sum | 108 ++++-----
sdks/java/io/google-ads/build.gradle | 4 +-
.../apache/beam/sdk/io/googleads/GoogleAdsIO.java | 6 +-
.../{GoogleAdsV23.java => GoogleAdsV25.java} | 56 ++---
.../sdk/io/googleads/DummyRateLimitPolicy.java | 2 +-
.../beam/sdk/io/googleads/GoogleAdsIOTest.java | 40 ++--
.../io/googleads/MockGoogleAdsClientFactory.java | 10 +-
.../apache/beam/sdk/io/gcp/spanner/SpannerIO.java | 26 ++-
.../changestreams/action/ActionFactory.java | 1 +
.../action/QueryChangeStreamAction.java | 7 +-
.../dofn/ReadChangeStreamPartitionDoFn.java | 11 +-
.../dofn/ReadChangeStreamPartitionDoFnTest.java | 3 +-
.../sdk/io/iceberg/cdc/sink/OrderedCommitFn.java | 2 -
.../beam/sdk/io/iceberg/cdc/sink/WriteCdcRows.java | 9 +-
.../sdk/io/iceberg/cdc/sink/CommitDeltasTest.java | 3 +-
sdks/python/apache_beam/coders/row_coder_test.py | 19 ++
sdks/python/apache_beam/dataframe/frames.py | 4 +-
sdks/python/apache_beam/dataframe/frames_test.py | 6 +
sdks/python/apache_beam/ml/inference/base.py | 7 +-
sdks/python/apache_beam/ml/inference/base_test.py | 98 ++++++++
.../apache_beam/ml/inference/model_manager.py | 2 +-
.../apache_beam/ml/inference/model_manager_test.py | 6 +-
.../python/apache_beam/runners/dask/dask_runner.py | 16 +-
.../apache_beam/runners/dask/dask_runner_test.py | 173 ++++++++++++++
.../runners/dask/transform_evaluator.py | 42 +++-
sdks/python/apache_beam/transforms/async_dofn.py | 40 ++--
.../apache_beam/transforms/async_dofn_test.py | 80 ++++++-
.../enrichment_handlers/vertex_ai_feature_store.py | 19 +-
.../vertex_ai_feature_store_test.py | 40 ++++
sdks/python/apache_beam/transforms/util.py | 6 +-
sdks/python/apache_beam/transforms/util_test.py | 16 ++
sdks/python/apache_beam/typehints/schemas.py | 23 +-
.../e2e/delta_lake_cdc_to_iceberg.yaml | 94 ++++++++
.../extended_tests/e2e/iceberg_cdc_to_iceberg.yaml | 156 +++++++++++++
sdks/python/apache_beam/yaml/integration_tests.py | 34 +++
sdks/python/apache_beam/yaml/standard_io.yaml | 1 +
website/www/site/content/en/roadmap/portability.md | 2 +-
44 files changed, 1278 insertions(+), 224 deletions(-)
rename .github/workflows/{update-googleads-version.yml =>
beam_Upgrade_Google_Ads_Version.yml} (89%)
create mode 100644 .github/workflows/gemini_code_review.yml
rename
sdks/java/io/google-ads/src/main/java/org/apache/beam/sdk/io/googleads/{GoogleAdsV23.java
=> GoogleAdsV25.java} (93%)
create mode 100644
sdks/python/apache_beam/yaml/extended_tests/e2e/delta_lake_cdc_to_iceberg.yaml
create mode 100644
sdks/python/apache_beam/yaml/extended_tests/e2e/iceberg_cdc_to_iceberg.yaml
