async def METHOD_NAME(self):
    for retry in range(1, 10):
        try:
            return await asyncssh.connect(**self._parameters)
        except (
            ConnectionResetError,
            asyncssh.DisconnectError,
            asyncssh.ConnectionLost,
            BrokenPipeError,
        ):
            await asyncio.sleep(retry * 10)
    return await asyncssh.connect(**self._parameters)