Method release

contrib/multilingual/api_pool.py:260–300

Release a slot on *key* back to the pool. Parameters ---------- key : The key previously obtained from :meth:`acquire`. success : ``True`` if the API call succeeded; ``False`` if it failed with a rate-limit error (HTTP 429). On fa

(self, key: ApiKey, *, success: bool = True)

            return key

    def release(self, key: ApiKey, *, success: bool = True) -> None:
        """Release a slot on *key* back to the pool.

        Parameters
        ----------
        key :
            The key previously obtained from :meth:`acquire`.
        success :
            ``True`` if the API call succeeded; ``False`` if it failed with
            a rate-limit error (HTTP 429).  On failure the key is marked
            rate-limited with exponential backoff.
        """
        with self._condition:
            key.active_requests = max(0, key.active_requests - 1)

            if success:
                key.consecutive_429 = 0
                logger.debug(
                    "Pool: released slot on key …%s (%d/%d active)",
                    key.key[-8:],
                    key.active_requests,
                    key.max_concurrent,
                )
            else:
                key.consecutive_429 += 1
                backoff = min(
                    _BACKOFF_BASE_S * (2 ** (key.consecutive_429 - 1)),
                    _BACKOFF_CAP_S,
                )
                key.rate_limited_until = time.monotonic() + backoff
                key.rate_limited = True
                self._rate_limits_hit += 1
                logger.warning(
                    "Pool: key …%s rate-limited for %.0fs "
                    "(consecutive=%d)",
                    key.key[-8:],
                    backoff,
                    key.consecutive_429,
                )

            self._condition.notify_all()

    def record_retry_success(self) -> None:
        """Increment the retry-success counter for reporting.