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 04ce0b6a82d Update BOM to 26.65.0 (#35854)
add deb9a0cc35c [Prism] Fix resource (docker container) leak when shutting
down (#35991)
add 6e89a7e2ab7 Pin onnx version (#36010)
add 01feaea59ca Bump cloud.google.com/go/bigtable from 1.38.0 to 1.39.0 in
/sdks (#36006)
add 5d7a8efb1b0 Revert "Add AftersynchronizedProcessing Time as
continuation trigger in Pytho…" (#35963)
add cffedbee518 Remove bad session test from SpannerReadIT (#36009)
add e67a5a26452 fix(mongodb): update filter composition to handle MongoDB
5.x driver (#36004)
add 4bcef0bd791 Update beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml
(#36015)
add 372b25b7571 Add GitHub Actions workflow for managing GCP Service
Account keys (#35911)
add dab5f5d7905 YAML example suite update (#35960)
add 258b8d1ed50 [Prism] Surface log format option and improve logging
presentation (#36008)
No new revisions were added by this update.
Summary of changes:
.github/trigger_files/beam_PostCommit_SQL.json | 2 +-
... => beam_Infrastructure_ServiceAccountKeys.yml} | 46 ++++---
.../beam_PostCommit_Python_Xlang_Gcp_Dataflow.yml | 4 +-
examples/yaml/README.md | 54 ++++++++
infra/keys/README.md | 14 +-
infra/keys/config.yaml | 4 -
infra/keys/gcp_logger.py | 153 ---------------------
infra/keys/keys.py | 101 +++++++-------
infra/keys/keys.yaml | 2 +-
sdks/go.mod | 2 +-
sdks/go.sum | 4 +-
sdks/go/pkg/beam/core/runtime/harness/harness.go | 2 +-
.../beam/runners/prism/internal/environments.go | 4 +-
sdks/go/pkg/beam/runners/prism/internal/execute.go | 3 +-
.../beam/runners/prism/internal/jobservices/job.go | 18 ++-
.../beam/runners/prism/internal/worker/worker.go | 42 +++++-
.../runners/prism/internal/worker/worker_test.go | 7 +-
sdks/java/extensions/sql/build.gradle | 2 +
.../sql/meta/provider/mongodb/MongoDbTable.java | 19 ++-
.../beam/sdk/io/gcp/spanner/SpannerReadIT.java | 55 --------
.../python/apache_beam/options/pipeline_options.py | 7 +
.../runners/portability/prism_runner.py | 53 +++++++
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 -------
.../transforms/ml/sentiment_analysis/README.md | 21 ++-
.../streaming_sentiment_analysis.yaml | 29 ++--
.../examples/transforms/ml/taxi_fare/README.md | 21 ++-
.../custom_nyc_taxifare_model_deployment.ipynb | 2 +-
.../taxi_fare/streaming_taxifare_prediction.yaml | 2 +-
sdks/python/tox.ini | 1 +
32 files changed, 342 insertions(+), 532 deletions(-)
copy .github/workflows/{beam_Infrastructure_UsersPermissions.yml =>
beam_Infrastructure_ServiceAccountKeys.yml} (54%)
create mode 100644 examples/yaml/README.md
delete mode 100644 infra/keys/gcp_logger.py
