This is an automated email from the ASF dual-hosted git repository.
yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 120ceab62a7 Fix renaming of embeddable_to_dict_fn (#37646)
120ceab62a7 is described below
commit 120ceab62a70a23416409e8771fdfb42391163ba
Author: Vitaly Terentyev <[email protected]>
AuthorDate: Thu Feb 19 19:29:17 2026 +0400
Fix renaming of embeddable_to_dict_fn (#37646)
---
examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb | 2 +-
sdks/python/apache_beam/ml/rag/ingestion/bigquery_it_test.py | 2 +-
2 files changed, 2 insertions(+), 2 deletions(-)
diff --git
a/examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb
b/examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb
index b1becd294ff..318d1329f3d 100644
--- a/examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb
+++ b/examples/notebooks/beam-ml/bigquery_vector_ingestion_and_search.ipynb
@@ -1275,7 +1275,7 @@
" },\n",
" schema_config=SchemaConfig(\n",
" schema=SCHEMA,\n",
- " chunk_to_dict_fn=chunk_to_dict_custom\n",
+ " embeddable_to_dict_fn=chunk_to_dict_custom\n",
" )\n",
")"
],
diff --git a/sdks/python/apache_beam/ml/rag/ingestion/bigquery_it_test.py
b/sdks/python/apache_beam/ml/rag/ingestion/bigquery_it_test.py
index b21da044346..7ab2472341d 100644
--- a/sdks/python/apache_beam/ml/rag/ingestion/bigquery_it_test.py
+++ b/sdks/python/apache_beam/ml/rag/ingestion/bigquery_it_test.py
@@ -138,7 +138,7 @@ class BigQueryVectorWriterConfigTest(unittest.TestCase):
'name': 'source', 'type': 'STRING'
}]
},
- chunk_to_dict_fn=lambda chunk: {
+ embeddable_to_dict_fn=lambda chunk: {
'id': chunk.id, 'embedding': chunk.embedding.dense_embedding,
'source': chunk.metadata.get('source')
})
