Function _connect_kms

pymongo/asynchronous/encryption.py:119–123

(address: _Address, opts: PoolOptions)

async def _connect_kms(address: _Address, opts: PoolOptions) -> Union[socket.socket, _sslConn]:
    try:
        return await _async_configured_socket(address, opts)
    except Exception as exc:
        _raise_connection_failure(address, exc, timeout_details=_get_timeout_details(opts))


@contextlib.contextmanager