diff --git a/src/langchain_google_alloydb_pg/async_vectorstore.py b/src/langchain_google_alloydb_pg/async_vectorstore.py index 522ba329..2b0eced9 100644 --- a/src/langchain_google_alloydb_pg/async_vectorstore.py +++ b/src/langchain_google_alloydb_pg/async_vectorstore.py @@ -525,13 +525,17 @@ async def __query_collection( async with self.engine.connect() as conn: await conn.execute(text(query_options_stmt)) result = await conn.execute(text(stmt)) + print("!!!!", stmt) result_map = result.mappings() results = result_map.fetchall() + print(">>>>", results) else: async with self.engine.connect() as conn: result = await conn.execute(text(stmt)) + print("!!!!@@@@", stmt) result_map = result.mappings() results = result_map.fetchall() + print(">>>>", results) return results async def asimilarity_search(