INNER CODE UNIT · Python

__init__

xinyitang3/cfnb · main.py:709

    def __init__(self, token_list, concurrency, min_interval, trust_env, failure_threshold):
        self.token_list = token_list
        self.current_token_index = 0
        self.token_lock = asyncio.Lock()
        self.semaphore = asyncio.Semaphore(concurrency)
        self.min_interval = min_interval
        self.last_request_time = 0
        self.rate_lock = asyncio.Lock()
        self.session = None
        self.trust_env = trust_env
        self.failure_threshold = failure_threshold
        self.token_failures = [0] * len(token_list)

    async def __aenter__(self):
        self.session = aiohttp.ClientSession(trust_env=self.trust_env)
        return self

    async def __aexit__(self, exc_type, exc_val, exc_tb):

View source record →