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 6b412be commit c6179ccCopy full SHA for c6179cc
tests/test_prepare.py
@@ -355,7 +355,10 @@ async def test_prepare_18_empty_result(self):
355
async def test_prepare_19_concurrent_calls(self):
356
st = self.loop.create_task(self.con.fetchval(
357
'SELECT ROW(pg_sleep(0.02), 1)'))
358
- await asyncio.sleep(0, loop=self.loop)
+
359
+ # Wait for some time to make sure the first query is fully
360
+ # prepared (!) and is now awaiting the results (!!).
361
+ await asyncio.sleep(0.01, loop=self.loop)
362
363
with self.assertRaisesRegex(asyncpg.InterfaceError,
364
'another operation'):
0 commit comments