o "hU@sdZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z mZe eZddddded efd eee gdfd ed ed eejdeegefdeddfddZdS)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 TelegramErrorTimedOut) on_err_cb stop_event is_running action_cb.r descriptionintervalr r max_retriesreturnc sd|d|p dd}dtffdd }td|} d } |rzz|Id Hs5WW| d 7} d SWntyY} zd } td | | | | j} WYd } ~ nld } ~ wtys} ztd| d } WYd } ~ nRd } ~ wtyt dt y}z3|r|||d ks| |krtd| |n t d| || d krd nt dd| } WYd }~nd }~ww|} W| d 7} n| d 7} w| rt | Id H|s%d Sd S)aDPerform a loop calling `action_cb`, retrying after network errors. Stop condition for loop: * `is_running()` evaluates :obj:`False` or * return value of `action_cb` evaluates :obj:`False` * or `stop_event` is set. * 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. zNetwork Retry Loop (z):cSsdS)NTrrrR/var/www/html/venv/lib/python3.10/site-packages/telegram/ext/_utils/networkloop.pyYsz$network_retry_loop..rcss IdHSt}t}tj||ftjdIdH\}}ttj|D]}|q.Wdn1s?wY||vrPt ddS| S)N) return_whenz %s CancelledF) asyncio create_taskwaitFIRST_COMPLETED contextlibsuppressCancelledErrorcancel_LOGGERdebugresult)action_cb_task stop_taskdonependingtaskr log_prefixr rr do_action[s"     z%network_retry_loop..do_actionz %s StartingrNg?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?)boolrrrinfo _retry_after total_secondsr r exceptionrminrsleep)r r rrr r reffective_is_runningr( cur_intervalretriesexc slack_timetoe telegram_excrr&rnetwork_retry_loop,s^ ,    "  &r9)__doc__rrcollections.abcrtypingrrtelegram._utils.loggingrtelegram.errorrrrr __name__rstrfloatEventr+intr9rrrrs8