We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eee847d commit d245ceaCopy full SHA for d245cea
clickhouse_sqlalchemy/drivers/asynch/connector.py
@@ -1,10 +1,11 @@
1
import asyncio
2
3
+from sqlalchemy.connectors.asyncio import AsyncAdapt_dbapi_cursor
4
from sqlalchemy.engine.interfaces import AdaptedConnection
5
from sqlalchemy.util.concurrency import await_only
6
7
-class AsyncAdapt_asynch_cursor:
8
+class AsyncAdapt_asynch_cursor(AsyncAdapt_dbapi_cursor):
9
__slots__ = (
10
'_adapt_connection',
11
'_connection',
@@ -14,6 +15,7 @@ class AsyncAdapt_asynch_cursor:
14
15
)
16
17
def __init__(self, adapt_connection):
18
+ super().__init__(adapt_connection)
19
self._adapt_connection = adapt_connection
20
self._connection = adapt_connection._connection # noqa
21
self.await_ = adapt_connection.await_
0 commit comments