Gecko [ kursiwala.pk ]

Linux spg20.cloudpowerdns.com 5.14.0-611.35.1.el9_7.x86_64 #1 SMP PREEMPT_DYNAMIC Wed Feb 25 03:46:09 EST 2026 x86_64
LiteSpeed
Server IP : 46.4.120.162 & Your IP : 216.73.216.163
Domains : Cant Read [ /etc/named.conf ]
User : seatingsolutions

Name	Size	Permission	Date
__pycache__	[ DIR ]	drwxr-xr-x	2026-03-26 16:29
asyncio	[ DIR ]	drwxr-xr-x	2026-03-26 16:29
commands	[ DIR ]	drwxr-xr-x	2026-03-26 16:29
__init__.py	1.71 KB	-rw-r--r--	2022-06-11 19:53
backoff.py	2.61 KB	-rw-r--r--	2022-06-11 19:53
client.py	74.51 KB	-rw-r--r--	2022-06-11 19:53
cluster.py	82.23 KB	-rw-r--r--	2022-06-11 19:53
compat.py	242 B	-rw-r--r--	2022-06-11 19:53
connection.py	59.77 KB	-rw-r--r--	2022-06-11 19:53
crc.py	729 B	-rw-r--r--	2022-06-11 19:53
exceptions.py	4.54 KB	-rw-r--r--	2022-06-11 19:53
lock.py	11.31 KB	-rw-r--r--	2022-06-11 19:53
ocsp.py	11.18 KB	-rw-r--r--	2022-06-11 19:53
retry.py	1.77 KB	-rw-r--r--	2022-06-11 19:53
sentinel.py	12.33 KB	-rw-r--r--	2022-06-11 19:53
typing.py	2.07 KB	-rw-r--r--	2022-06-11 19:53
utils.py	1.62 KB	-rw-r--r--	2022-06-11 19:53

Rename

import socket
from time import sleep

from redis.exceptions import ConnectionError, TimeoutError

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

def __init__(
        self,
        backoff,
        retries,
        supported_errors=(ConnectionError, TimeoutError, socket.timeout),
    ):
        """
        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

def update_supported_errors(self, specified_errors: list):
        """
        Updates the supported errors with the specified error types
        """
        self._supported_errors = tuple(
            set(self._supported_errors + tuple(specified_errors))
        )

def call_with_retry(self, do, fail):
        """
        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 do()
            except self._supported_errors as error:
                failures += 1
                fail(error)
                if self._retries >= 0 and failures > self._retries:
                    raise error
                backoff = self._backoff.compute(failures)
                if backoff > 0:
                    sleep(backoff)