YPi6dZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z mZe eZdddddd ed efd eee gdfd ed edeej&deegefdededdfdZy)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_retriesrreturncK|r|dk\r tdd|d|xsd}dfd } tjd|} d} |r_ | d{|stjd  | d z } y |} | d z } | rtj| d{|r^yy7T#t$rA} d } tj d | | | | j j z} Yd} ~ ud} ~ wt$r#}tjd |d} Yd}~d}~wt$rtjdt$rg}|r|||dks| |krtjd| |ntjd| || dk(rd ntdd| z} Yd}~,d}~wwxYw#| d z } wxYw7w)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)NTrU/root/twitch_bot/venv/lib/python3.12/site-packages/telegram/ext/_utils/networkloop.pyz$network_retry_loop..isrNcKsd{ytj}tjj}tj||ftjd{\}}t j tj 5|D]}|j ddd||vrtjdy|jy77y#1swY9xYww)N) return_whenz %s Cancelled) asyncio create_taskwaitFIRST_COMPLETED contextlibsuppressCancelledErrorcancel_LOGGERdebugresult)action_cb_task stop_taskdonependingtaskr log_prefixr s r do_actionz%network_retry_loop..do_actionks+    ,,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/%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) ValueErrorr$r%rinfo _retry_after total_secondsr r exceptionr minrsleep)rr rrr r rreffective_is_runningr- cur_intervalretriesexc slack_timetoe telegram_excr,s` ` @rnetwork_retry_loopr>-sn[A-RSS' }B7J%7, , MM-,LG  & +  $ CZPD qLGI%D$L qLG -- - - -U   IJ LLA:sT^ &(8(8(F(F(HHL  MMCZQT UL    F S  S,'Q'K"7 > GU`!!> GU`!- 11s2s\?Q7RL S& qLG .sA G B0B.B07G>F4GF> G,G.B00 F197C50F45 F1DF4+F1 AF,&F4,F11F44F;;G)__doc__rr collections.abcrtypingrrtelegram._utils.loggingrtelegram.errorrrr r __name__r$strfloatEventboolintr>rrrrJs& %%.LL X  <@+//3#A.Y'A.-$!678A. A.  A. ' A."d(+,A.A.A. A.r