You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2025/06/11 13:20:03 UTC

(beam) branch master updated (adc40f93dce -> 6c12a845536)

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

damccorm pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


    from adc40f93dce Remove breaking PDone change (#35224)
     add 6c12a845536 Generic Postgres + Cloudsql postgres embeddings. (#35215)

No new revisions were added by this update.

Summary of changes:
 .../beam_PostCommit_Python_Xlang_Gcp_Direct.json   |   2 +-
 CHANGES.md                                         |   1 +
 .../schemaio-expansion-service/build.gradle        |   2 +
 sdks/python/apache_beam/internal/gcp/auth_test.py  |   1 +
 .../apache_beam/io/gcp/datastore/v1new/helper.py   |   2 +-
 .../apache_beam/ml/gcp/recommendations_ai.py       |   2 +-
 .../apache_beam/ml/gcp/videointelligenceml.py      |   3 +-
 sdks/python/apache_beam/ml/gcp/visionml.py         |   3 +-
 .../python/apache_beam/ml/rag/ingestion/alloydb.py | 783 ++-------------------
 .../ml/rag/ingestion/alloydb_it_test.py            | 343 +++++----
 .../apache_beam/ml/rag/ingestion/cloudsql.py       | 220 ++++++
 .../ml/rag/ingestion/cloudsql_it_test.py           | 223 ++++++
 .../apache_beam/ml/rag/ingestion/jdbc_common.py    |  78 ++
 .../apache_beam/ml/rag/ingestion/postgres.py       | 209 ++++++
 .../ingestion/{alloydb.py => postgres_common.py}   | 483 ++-----------
 .../{alloydb_it_test.py => postgres_it_test.py}    | 293 ++------
 .../apache_beam/ml/rag/ingestion/test_utils.py     | 105 +++
 sdks/python/setup.py                               |   1 +
 18 files changed, 1206 insertions(+), 1548 deletions(-)
 create mode 100644 sdks/python/apache_beam/ml/rag/ingestion/cloudsql.py
 create mode 100644 sdks/python/apache_beam/ml/rag/ingestion/cloudsql_it_test.py
 create mode 100644 sdks/python/apache_beam/ml/rag/ingestion/jdbc_common.py
 create mode 100644 sdks/python/apache_beam/ml/rag/ingestion/postgres.py
 copy sdks/python/apache_beam/ml/rag/ingestion/{alloydb.py => postgres_common.py} (56%)
 copy sdks/python/apache_beam/ml/rag/ingestion/{alloydb_it_test.py => postgres_it_test.py} (76%)
 create mode 100644 sdks/python/apache_beam/ml/rag/ingestion/test_utils.py