Skip to content

Commit 742ffc2

Browse files
committed
fix AsyncStatement::close()
1 parent a8bfdbb commit 742ffc2

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

firebirdsql/aio/fbcore.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -154,7 +154,7 @@ async def prepare(self, sql, explain_plan=False):
154154
async def close(self):
155155
DEBUG_OUTPUT("AsyncStatement::close()", self.handle)
156156
if self.stmt_type == isc_info_sql_stmt_select and self._is_open:
157-
self.trans.connection._op_free_statement(self.handle, DSQL_close)
157+
await self.trans.connection._async_op_free_statement(self.handle, DSQL_close)
158158
if (self.trans.connection.accept_type & ptype_MASK) == ptype_lazy_send:
159159
self.trans.connection.lazy_response_count += 1
160160
else:

firebirdsql/tests/test_async.py

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,7 +63,7 @@ async def _test_select():
6363
result = await cur.fetchall()
6464
self.assertEqual(result, [(42, ), ])
6565
await cur.close()
66-
conn.close()
66+
await conn.close()
6767
loop.run_until_complete(_test_select())
6868
loop.close()
6969

0 commit comments

Comments
 (0)