Skip to content

Commit 061c16f

Browse files
committed
Fix async cursor fetch methods
1 parent 2eacadb commit 061c16f

File tree

3 files changed

+5
-5
lines changed

3 files changed

+5
-5
lines changed

requirements.txt

+1-1
Original file line numberDiff line numberDiff line change
@@ -1,3 +1,3 @@
11
sqlalchemy >= 1.4.0, < 3.0.0
22
ydb >= 3.18.8
3-
ydb-dbapi >= 0.1.7
3+
ydb-dbapi >= 0.1.8

tox.ini

+1-1
Original file line numberDiff line numberDiff line change
@@ -17,7 +17,7 @@ ignore_errors = True
1717
commands =
1818
docker-compose up -d
1919
python {toxinidir}/wait_container_ready.py
20-
pytest -v {posargs}
20+
pytest -v {posargs} --dbdriver ydb --dbdriver ydb_async
2121
docker-compose down
2222

2323
[testenv:test-all]

ydb_sqlalchemy/sqlalchemy/dbapi_adapter.py

+3-3
Original file line numberDiff line numberDiff line change
@@ -87,13 +87,13 @@ def rowcount(self):
8787
return self._cursor.rowcount
8888

8989
def fetchone(self):
90-
return await_only(self._cursor.fetchone())
90+
return self._cursor.fetchone()
9191

9292
def fetchmany(self, size=None):
93-
return await_only(self._cursor.fetchmany(size=size))
93+
return self._cursor.fetchmany(size=size)
9494

9595
def fetchall(self):
96-
return await_only(self._cursor.fetchall())
96+
return self._cursor.fetchall()
9797

9898
def execute_scheme(self, sql, parameters=None):
9999
return await_only(self._cursor.execute_scheme(sql, parameters))

0 commit comments

Comments
 (0)