Fix test_prepare_19_concurrent_calls test

1st1 · 1st1 · commit 14ab4f290001 · 2016-08-02T17:51:10.000-04:00
diff --git a/tests/test_prepare.py b/tests/test_prepare.py
@@ -353,15 +353,16 @@ async def test_prepare_18_empty_result(self):
 self.assertIsNone(await self.con.fetchrow(''))
 
 async def test_prepare_19_concurrent_calls(self):
- st = self.loop.create_task(self.con.prepare('SELECT 1'))
+ st = self.loop.create_task(self.con.prepare(
+ 'SELECT ROW(pg_sleep(0.02), 1)'))
 await asyncio.sleep(0, loop=self.loop)
 
 with self.assertRaisesRegex(asyncpg.InterfaceError,
 'another operation'):
 await self.con.execute('SELECT 2')
 
 st = await st
- self.assertEqual(await st.fetchval(), 1)
+ self.assertEqual(await st.fetchval(), (None, 1))
 
 async def test_prepare_20_concurrent_calls(self):
 for methname, val in [('fetch', [(1,)]),

-Original file line number
+Diff line change
 self.assertIsNone(awaitself.con.fetchrow(''))
 asyncdeftest_prepare_19_concurrent_calls(self):
 -st=self.loop.create_task(self.con.prepare('SELECT 1'))
 +st=self.loop.create_task(self.con.prepare(
 +'SELECT ROW(pg_sleep(0.02), 1)'))
 awaitasyncio.sleep(0, loop=self.loop)
 withself.assertRaisesRegex(asyncpg.InterfaceError,
 'another operation'):
 awaitself.con.execute('SELECT 2')
 st=awaitst
 -self.assertEqual(awaitst.fetchval(), 1)
 +self.assertEqual(awaitst.fetchval(), (None, 1))
 asyncdeftest_prepare_20_concurrent_calls(self):
 formethname, valin [('fetch', [(1,)]),