async def run(): conn = await asyncpg.connect(db_url) values = await conn.fetch('''SELECT ... FROM ... WHERE ...;''') await conn.close() return values