(con)
| 520 | async with self.create_pool(database='postgres', |
| 521 | min_size=1, max_size=1) as pool: |
| 522 | async def get_xact_id(con): |
| 523 | return await con.fetchval('select txid_current()') |
| 524 | |
| 525 | with self.assertLoopErrorHandlerCalled('an active transaction'): |
| 526 | async with pool.acquire() as con: |