Function _can_use_connection

asyncpg/connect_utils.py:1200–1202

(connection, attr: SessionAttribute)

async def _can_use_connection(connection, attr: SessionAttribute):
    can_use = target_attrs_check[attr]
    return await can_use(connection)


async def _connect(*, loop, connection_class, record_class, **kwargs):