'idZddlZddlZddlmZmZddlmZddlm Z m Z m Z m Z ee Zdddddded efd ee gdfdzd ed ed ej"dzdegefdzdededdfdZy)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)Callable Coroutine) get_logger) InvalidToken RetryAfter TelegramErrorTimedOutF) on_err_cb stop_event is_runningrepeat_on_success action_cb.r descriptionintervalr r max_retriesr returnc8K|rdk\r tdd|d|xsd}ddtdtdtffd } dfd } tj d |} d} |r_ | d {|stj d  | dz } y |} | dz } | rtj| d {|r^y y 7T#t $r;} d}|| jjz} | d|d}| | |rYd } ~ od } ~ wt$r}d} d|d}| | |rYd }~d }~wt$rtjdt$r3}|r||| | r| dk(rdntdd| z} Yd }~d }~wwxYw#| dz } wxYw7ݭw)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):cy)NTri/home/obispo/Crisostomo_bridge/mision_env/lib/python3.12/site-packages/telegram/ext/_utils/networkloop.pyz$network_retry_loop..hsrcurrent_retriesexception_inforc|rd|n}dks|krtjd||ytjd||y)aLCheck if max retries reached and log accordingly. Args: current_retries: The current retry count. exception_info: Additional context about the exception (e.g., "Timed out: ..."). Returns: bool: True if max retries reached (should abort), False otherwise (should retry).  rz(%s Failed run number %s of %s. Retrying.Fz(%s Failed run number %s of %s. Aborting.T)_LOGGERdebug exception)rrprefix_with_info log_prefixrs rcheck_max_retries_and_logz5network_retry_loop..check_max_retries_and_logjsh@Nj\>*:;S] ?o ; MM:     6     rNcKsd{ytj}tjj}tj||ftjd{\}}t j tj 5|D]}|j ddd||vrtjdy|jy77y#1swY9xYww)N) return_whenz %s Cancelled) asyncio create_taskwaitFIRST_COMPLETED contextlibsuppressCancelledErrorcancelrrresult)action_cb_task stop_taskdonependingtaskrr!r s r do_actionz%network_retry_loop..do_actions+    ,,Y[9'' (9: %ll Y 'W5L5L  g !7!7 8        MM.* 5  %     s: DC5A,D=C7>*D(C95D7D9D>Dz %s Startingz#%s Action succeeded. Stopping loop.g?z . Adding z seconds to the specified time.z Timed out: .z&%s Invalid token. Aborting retry loop.g?))rN) ValueErrorintstrboolrrr _retry_after total_secondsr rrrminr%sleep)rr rrr r rr effective_is_runningr"r3 cur_intervalretriesexc slack_timertoe telegram_excr!s` ` ` @rnetwork_retry_looprG,sn[A-RSS' }B7J%7,3UY8 , MM-,LG  % +  $ CZPB qLGG%B$L qLG -- - - -S   J%(8(8(F(F(HHL #uIj\9XYN).AB L*3%q1N).AB    F S  S,'(1!- 11s2s\?Q7RL S qLG .sA#F* C 4C 5C FFF:F; FF C F 1D F F D-(F-+F )FFF  FFF)__doc__r%r)collections.abcrrtelegram._utils.loggingrtelegram.errorrrrr __name__rr:floatEventr;r9rGrrrrOs& /.LL X  9=(,,0#\.Y'\.-.5\. \.  \.  $ \.T"T)\.\.\. \.r