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 4aba1b6 commit cb419e4Copy full SHA for cb419e4
test/integ/test_async.py
@@ -245,10 +245,10 @@ def test_close_connection_with_completed_async_queries(conn_cnx):
245
cur.execute_async("select 2")
246
qid2 = cur.sfqid
247
while con.is_still_running(
248
- con._get_query_status(qid1)
+ con._get_query_status(qid1)[0]
249
): # use _get_query_status to avoid caching
250
time.sleep(1)
251
- while con.is_still_running(con._get_query_status(qid2)):
+ while con.is_still_running(con._get_query_status(qid2)[0]):
252
253
assert con._all_async_queries_finished()
254
assert len(con._done_async_sfqids) == 2 and con.rest is None
0 commit comments