diff --git a/ydb_sqlalchemy/sqlalchemy/dbapi_adapter.py b/ydb_sqlalchemy/sqlalchemy/dbapi_adapter.py index 66f72ae..e7a3f47 100644 --- a/ydb_sqlalchemy/sqlalchemy/dbapi_adapter.py +++ b/ydb_sqlalchemy/sqlalchemy/dbapi_adapter.py @@ -66,7 +66,10 @@ def get_table_names(self): return await_only(self._connection.get_table_names()) +# TODO(vgvoleg): Migrate to AsyncAdapt_dbapi_cursor and AsyncAdapt_dbapi_connection class AdaptedAsyncCursor: + _awaitable_cursor_close: bool = False + def __init__(self, cursor: AsyncCursor): self._cursor = cursor @@ -112,3 +115,6 @@ def setinputsizes(self, *args): def setoutputsizes(self, *args): pass + + async def _async_soft_close(self) -> None: + pass