This is an automated email from the ASF dual-hosted git repository.

damccorm pushed a commit to branch users/damccorm/test-revert
in repository https://gitbox.apache.org/repos/asf/beam.git

commit f11ebca769523a925265f9cb876b1dadf4c55524
Merge: 07d7dc7bd6f 8f888fb171a
Author: Danny Mccormick <[email protected]>
AuthorDate: Mon Aug 18 14:52:22 2025 -0400

    Merge branch 'master' of https://github.com/apache/beam into 
users/damccorm/test-revert

 CHANGES.md                                         |   2 +
 sdks/go.mod                                        |  16 +--
 sdks/go.sum                                        |  32 +++---
 sdks/go/pkg/beam/core/runtime/exec/userstate.go    |  67 ++++++-----
 sdks/go/test/integration/primitives/state.go       |  40 +++++++
 sdks/go/test/integration/primitives/state_test.go  |   5 +
 .../sdk/io/gcp/pubsub/PreparePubsubWriteDoFn.java  |  11 +-
 .../apache/beam/sdk/io/gcp/pubsub/PubsubIO.java    |   2 +-
 .../io/gcp/pubsub/PreparePubsubWriteDoFnTest.java  |  78 ++++++-------
 sdks/python/apache_beam/ml/inference/base_test.py  |   2 +-
 sdks/python/apache_beam/transforms/core.py         |   9 ++
 .../python/apache_beam/typehints/typecheck_test.py |   9 ++
 sdks/python/apache_beam/yaml/examples/README.md    |   5 +-
 .../yaml/examples/testing/examples_test.py         | 125 +++++++++++++++++++--
 .../yaml/examples/testing/input_data.py            |  43 +++++++
 .../examples/transforms/ml/log_analysis/README.md  |  98 ++++++++++++++++
 .../ml/log_analysis/anomaly_scoring.yaml           |  93 +++++++++++++++
 .../ml/log_analysis/batch_log_analysis.sh          | 108 ++++++++++++++++++
 .../ml/log_analysis/iceberg_migration.yaml         |  45 ++++++++
 .../ml/log_analysis/ml_preprocessing.yaml          | 124 ++++++++++++++++++++
 .../transforms/ml/log_analysis/requirements.txt    |  24 ++++
 .../examples/transforms/ml/log_analysis/train.py   |  89 +++++++++++++++
 sdks/python/apache_beam/yaml/yaml_testing.py       |  36 ++++--
 sdks/python/apache_beam/yaml/yaml_testing_test.py  |  99 +++++++++++++++-
 .../container/py310/base_image_requirements.txt    |   4 +-
 .../container/py310/ml_image_requirements.txt      |   4 +-
 .../container/py311/base_image_requirements.txt    |   4 +-
 .../container/py311/ml_image_requirements.txt      |   4 +-
 .../container/py312/base_image_requirements.txt    |   4 +-
 .../container/py312/ml_image_requirements.txt      |   4 +-
 .../container/py313/base_image_requirements.txt    |   4 +-
 .../container/py39/base_image_requirements.txt     |   4 +-
 .../container/py39/ml_image_requirements.txt       |   4 +-
 33 files changed, 1074 insertions(+), 124 deletions(-)

Reply via email to