Method get_connection

redis/asyncio/connection.py:1814–1854

Gets a connection from the pool, blocking until one is available

(self, command_name=None, *keys, **options)

        version="5.3.0",
    )
    async def get_connection(self, command_name=None, *keys, **options):
        """Gets a connection from the pool, blocking until one is available"""
        # Start timing for wait time observability
        start_time_acquired = time.monotonic()

        try:
            async with self._condition:
                async with async_timeout(self.timeout):
                    await self._condition.wait_for(self.can_get_connection)
                    # Track connection count before to detect if a new connection is created
                    connections_before = len(self._available_connections) + len(
                        self._in_use_connections
                    )
                    start_time_created = time.monotonic()
                    connection = super().get_available_connection()
                    connections_after = len(self._available_connections) + len(
                        self._in_use_connections
                    )
                    is_created = connections_after > connections_before
        except asyncio.TimeoutError as err:
            raise ConnectionError("No connection available.") from err

        # We now perform the connection check outside of the lock.
        try:
            await self.ensure_connection(connection)

            if is_created:
                await record_connection_create_time(
                    connection_pool=self,
                    duration_seconds=time.monotonic() - start_time_created,
                )

            await record_connection_wait_time(
                pool_name=get_pool_name(self),
                duration_seconds=time.monotonic() - start_time_acquired,
            )

            return connection
        except BaseException:
            await self.release(connection)
            raise

    async def release(self, connection: AbstractConnection):
        """Releases the connection back to the pool."""