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 c5a9eef23a4 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#28117)
add 095cf278b4e Bump github.com/aws/aws-sdk-go-v2/config in /sdks (#28140)
add 58ac71f5994 Update TF notebook example to auto-restart the runtime
after dependency installation (#28132)
add c5404a1c079 Bump github.com/aws/aws-sdk-go-v2/feature/s3/manager in
/sdks (#28138)
add 0c6ef7dd478 Pass BQ coder to underlying avro source (#28143)
add 6bfb4693acf Bump cloud.google.com/go/spanner from 1.47.0 to 1.49.0 in
/sdks (#28144)
add 6ca4110e16d Always proxy RunInference with large models (#27989)
add d93200dde1e Free disk space before running build_release_candidate
(#28123)
add 2abff20dbe1 Add Java Neo4j IO Direct job (#28090)
add fef4cf8a028 Merge pull request #28124: Allow using CREATE_IF_NEEDED
when writing deletes or updates to BigQuery
add 44b639fdd7e [yaml] yaml_transform.py unit tests (#27338)
No new revisions were added by this update.
Summary of changes:
.github/workflows/README.md | 1 +
...yml => beam_PreCommit_Java_Neo4j_IO_Direct.yml} | 26 +-
.github/workflows/build_release_candidate.yml | 2 +
.../beam-ml/run_inference_tensorflow.ipynb | 383 ++++++++++-----------
sdks/go.mod | 6 +-
sdks/go.sum | 12 +-
.../beam/sdk/io/gcp/bigquery/BigQueryIO.java | 39 ++-
.../sdk/io/gcp/bigquery/BigQuerySourceBase.java | 28 +-
.../sdk/io/gcp/bigquery/CreateTableHelpers.java | 9 +
.../beam/sdk/io/gcp/bigquery/CreateTables.java | 5 +
.../sdk/io/gcp/bigquery/DynamicDestinations.java | 9 +
.../gcp/bigquery/DynamicDestinationsHelpers.java | 30 ++
.../bigquery/StorageApiDynamicDestinations.java | 36 +-
.../bigquery/StorageApiWriteUnshardedRecords.java | 1 +
.../bigquery/StorageApiWritesShardedRecords.java | 4 +-
.../sdk/io/gcp/bigquery/BigQueryIOReadTest.java | 19 +
.../gcp/bigquery/BigQueryIOStorageQueryTest.java | 13 +
.../io/gcp/bigquery/StorageApiSinkRowUpdateIT.java | 42 +--
.../apache/beam/sdk/io/neo4j/Neo4jTestUtil.java | 3 +-
.../inference/huggingface_language_modeling.py | 2 +-
sdks/python/apache_beam/ml/inference/base.py | 3 +-
.../ml/inference/huggingface_inference.py | 4 +
.../apache_beam/ml/inference/pytorch_inference.py | 1 +
sdks/python/apache_beam/yaml/yaml_transform.py | 2 +-
.../apache_beam/yaml/yaml_transform_scope_test.py | 204 +++++++++++
.../python/apache_beam/yaml/yaml_transform_test.py | 133 +------
.../apache_beam/yaml/yaml_transform_unit_test.py | 210 +++++++++++
sdks/python/tox.ini | 6 +
28 files changed, 783 insertions(+), 450 deletions(-)
copy .github/workflows/{beam_PreCommit_Java_JDBC_IO_Direct.yml =>
beam_PreCommit_Java_Neo4j_IO_Direct.yml} (80%)
create mode 100644 sdks/python/apache_beam/yaml/yaml_transform_scope_test.py
create mode 100644 sdks/python/apache_beam/yaml/yaml_transform_unit_test.py
