Function _close_candidates

asyncpg/connect_utils.py:1237–1241

(conns, chosen)

    finally:

        async def _close_candidates(conns, chosen):
            await asyncio.gather(
                *(c.close() for c in conns if c is not chosen),
                return_exceptions=True
            )
        if candidates:
            asyncio.create_task(
                _close_candidates(candidates, chosen_connection))