o N,h6@sdZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z mZe eZdddddd ed efd eee gdfd ed edeejdeegefdededdfddZdS)aThis module contains a network retry loop implementation. Its specifically tailored to handling the Telegram API and its errors. .. versionadded:: 21.11 Hint: It was originally part of the `Updater` class, but as part of #4657 it was extracted into its own module to be used by other parts of the library. Warning: Contents of this module are intended to be used internally by the library and *not* by the user. Changes to this module are not considered breaking changes and may not be documented in the changelog. N) Coroutine)CallableOptional) get_logger) InvalidToken RetryAfter TelegramErrorTimedOutF) on_err_cb stop_event is_runningrepeat_on_success action_cb.r descriptionintervalr r max_retriesr returnc s|r |dkr tdd|d|pdd}dfd d } td |} d} |rzz| IdH|sEtd WW| d 7} dSWntyi} zd} td| | | | j} WYd} ~ nld} ~ wty}ztd|d} WYd}~nRd}~wtyt dt y}z3|r|||dks| |krtd| |n t d| || dkrd nt dd| } WYd}~nd}~ww|} W| d 7} n| d 7} w| rt | IdH|s-dSdS)aPerform a loop calling `action_cb`, retrying after network errors. Stop condition for loop in case of ``max_retries < 0``: * `is_running()` evaluates :obj:`False` * `stop_event` is set. * calling `action_cb` succeeds and `repeat_on_success` is :obj:`False`. Additional stop condition for loop in case of `max_retries >= 0``: * a call to `action_cb` succeeds * or `max_retries` is reached. Args: action_cb (:term:`coroutine function`): Network oriented callback function to call. on_err_cb (:obj:`callable`): Optional. Callback to call when TelegramError is caught. Receives the exception object as a parameter. Hint: Only required if you want to handle the error in a special way. Logging about the error is already handled by the loop. Important: Must not raise exceptions! If it does, the loop will be aborted. description (:obj:`str`): Description text to use for logs and exception raised. interval (:obj:`float` | :obj:`int`): Interval to sleep between each call to `action_cb`. stop_event (:class:`asyncio.Event` | :obj:`None`): Event to wait on for stopping the loop. Setting the event will make the loop exit even if `action_cb` is currently running. Defaults to :obj:`None`. is_running (:obj:`callable`): Function to check if the loop should continue running. Must return a boolean value. Defaults to `lambda: True`. max_retries (:obj:`int`): Maximum number of retries before stopping the loop. * < 0: Retry indefinitely. * 0: No retries. * > 0: Number of retries. repeat_on_success (:obj:`bool`): Whether to repeat the action after a successful call. Defaults to :obj:`False`. Raises: ValueError: When passing `repeat_on_success=True` and `max_retries >= 0`. This case is currently not supported. rz7Cannot use repeat_on_success=True with max_retries >= 0zNetwork Retry Loop (z):cSsdS)NTrrrk/var/www/www-root/data/www/bot.pdev.uz/venv/lib/python3.10/site-packages/telegram/ext/_utils/networkloop.pyisz$network_retry_loop..rNcss IdHdSt}t}tj||ftjdIdH\}}ttj|D]}|q0Wdn1sAwY||vrRt ddS| dS)N) return_whenz %s Cancelled) asyncio create_taskwaitFIRST_COMPLETED contextlibsuppressCancelledErrorcancel_LOGGERdebugresult)action_cb_task stop_taskdonependingtaskr log_prefixr rr do_actionks$      z%network_retry_loop..do_actionz %s Startingz#%s Action succeeded. Stopping loop.g?z/%s %s. Adding %s seconds to the specified time.z'%s Timed out: %s. Retrying immediately.z&%s Invalid token. Aborting retry loop.z(%s Failed run number %s of %s. Retrying.z(%s Failed run number %s of %s. Aborting.g?)rN) ValueErrorrr rinfo _retry_after total_secondsr r exceptionrminrsleep)rr rrr r rr effective_is_runningr) cur_intervalretriesexc slack_timetoe telegram_excrr'rnetwork_retry_loop-sf 7      "  &r:)__doc__rrcollections.abcrtypingrrtelegram._utils.loggingrtelegram.errorrrrr __name__rstrfloatEventboolintr:rrrrs>