@@ -43,15 +43,15 @@ def psycopg_connect(dbapi_connection, connection_record):
43
43
psycopg_async_type_engine = create_async_engine ('postgresql+psycopg://localhost/pgvector_python_test' )
44
44
45
45
@event .listens_for (psycopg_async_type_engine .sync_engine ,"connect" )
46
- def connect (dbapi_connection ,connection_record ):
46
+ def psycopg_async_connect (dbapi_connection ,connection_record ):
47
47
from pgvector .psycopg import register_vector_async
48
48
dbapi_connection .run_async (register_vector_async )
49
49
50
50
asyncpg_engine = create_async_engine ('postgresql+asyncpg://localhost/pgvector_python_test' )
51
51
asyncpg_type_engine = create_async_engine ('postgresql+asyncpg://localhost/pgvector_python_test' )
52
52
53
53
@event .listens_for (asyncpg_type_engine .sync_engine ,"connect" )
54
- def connect (dbapi_connection ,connection_record ):
54
+ def asyncpg_connect (dbapi_connection ,connection_record ):
55
55
from pgvector .asyncpg import register_vector
56
56
dbapi_connection .run_async (register_vector )
57
57