(pool)
| 573 | return 1 |
| 574 | |
| 575 | async def test_execute_with_arg(pool): |
| 576 | i = random.randint(0, 20) |
| 577 | await asyncio.sleep(random.random() / 100) |
| 578 | r = await pool.execute('SELECT generate_series(0, $1)', i) |
| 579 | self.assertEqual(r, 'SELECT {}'.format(i + 1)) |
| 580 | return 1 |
| 581 | |
| 582 | async def run(N, meth): |
| 583 | async with self.create_pool(database='postgres', |