FileMgr

✏️ /usr/lib/python3.9/site-packages/redis/asyncio/retry.py

✕ Tutup

from asyncio import sleep
from typing import TYPE_CHECKING, Any, Awaitable, Callable, Tuple, Type, TypeVar

from redis.exceptions import ConnectionError, RedisError, TimeoutError

if TYPE_CHECKING:
    from redis.backoff import AbstractBackoff

T = TypeVar("T")

class Retry:
    """Retry a specific number of times after a failure"""

__slots__ = "_backoff", "_retries", "_supported_errors"

def __init__(
        self,
        backoff: "AbstractBackoff",
        retries: int,
        supported_errors: Tuple[Type[RedisError], ...] = (
            ConnectionError,
            TimeoutError,
        ),
    ):
        """
        Initialize a `Retry` object with a `Backoff` object
        that retries a maximum of `retries` times.
        `retries` can be negative to retry forever.
        You can specify the types of supported errors which trigger
        a retry with the `supported_errors` parameter.
        """
        self._backoff = backoff
        self._retries = retries
        self._supported_errors = supported_errors

async def call_with_retry(
        self, do: Callable[[], Awaitable[T]], fail: Callable[[RedisError], Any]
    ) -> T:
        """
        Execute an operation that might fail and returns its result, or
        raise the exception that was thrown depending on the `Backoff` object.
        `do`: the operation to call. Expects no argument.
        `fail`: the failure handler, expects the last error that was thrown
        """
        self._backoff.reset()
        failures = 0
        while True:
            try:
                return await do()
            except self._supported_errors as error:
                failures += 1
                await fail(error)
                if self._retries >= 0 and failures > self._retries:
                    raise error
                backoff = self._backoff.compute(failures)
                if backoff > 0:
                    await sleep(backoff)

Batal

⬅ redis 10 item

Nama	Tipe	Ukuran	Diubah	Perm	Aksi
📁 __pycache__	dir	—	16/09/24 06:48	0755	📂
🐍 __init__.py	py	1.4 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 client.py	py	51.1 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 cluster.py	py	53.2 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 connection.py	py	64 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 lock.py	py	11.5 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 parser.py	py	3.5 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 retry.py	py	1.9 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 sentinel.py	py	13.1 KB	12/06/22 02:53	0644	✏️ ⬇
🐍 utils.py	py	704 B	12/06/22 02:53	0644	✏️ ⬇

✏️ Rename

🔑 Ubah Permission