Skip to content

Commit ec46bdd

Browse files
committed
Fix create_vector_extension with async
1 parent 7748b92 commit ec46bdd

File tree

1 file changed

+0
-3
lines changed

1 file changed

+0
-3
lines changed

langchain_postgres/vectorstores.py

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -231,15 +231,12 @@ def _results_to_docs(docs_and_scores: Any) -> List[Document]:
231231

232232
def _create_vector_extension(conn: Connection) -> None:
233233
statement = sqlalchemy.text(
234-
"BEGIN;"
235234
"SELECT pg_advisory_xact_lock(1573678846307946496);"
236235
"CREATE EXTENSION IF NOT EXISTS vector;"
237-
"COMMIT;"
238236
)
239237
conn.execute(statement)
240238
conn.commit()
241239

242-
243240
DBConnection = Union[sqlalchemy.engine.Engine, str]
244241

245242

0 commit comments

Comments
 (0)