вы должны обернуть свой код внутри функции async
и вызвать его внутри цикла, например:
import asyncio
import asyncpg
async def test():
cs = "user:password@my_postgresql_server_ipaddr:port/database?name=db_name"
async with asyncpg.create_pool(dsn=cs) as pool:
print("pool created")
if __name__ == '__main__':
loop = asyncio.get_event_loop()
loop.run_until_complete(test())
loop.close()
подробнее: example-chain-coroutines