ynhdZddlZddlZddlmZddlmZmZddlm Z ddl m Z m Z m Z mZe eZddddded efd eee gdfd ed ed eej&deegefdeddfdZy)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"Kd|d|xsd}dtffd }tjd|} d} |rG |d{s | d z } y |} | d z } | rtj| d{|rFyy7<#t$r3} d } tj d | | | | j z} Yd} ~ gd} ~ wt $r#} tjd | d} Yd} ~ d} ~ wt$rtjd t$rg}|r|||dks| |krtjd| |ntjd| || dk(rd ntdd| z} Yd}~d}~wwxYw#| d z } wxYw7w)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):cy)NTr`/var/www/html/profi_bot/bot/venv/lib/python3.12/site-packages/telegram/ext/_utils/networkloop.pyz$network_retry_loop..Ys$rrc Ksd{Stj}tjj}tj||ftjd{\}}t j tj 5|D]}|j ddd||vrtjdy|jS77x#1swY8xYww)N) return_whenz %s CancelledF) asyncio create_taskwaitFIRST_COMPLETED contextlibsuppressCancelledErrorcancel_LOGGERdebugresult)action_cb_task stop_taskdonependingtaskr log_prefixr s r do_actionz%network_retry_loop..do_action[s"$ $ ,,Y[9'' (9: %ll Y 'W5L5L  g !7!7 8  9   MM.* 5$$&&% 9 8s: DC3A+D<C5=*D'C74D5D7D<Dz %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?) boolr#r$rinfo retry_afterr r exceptionr minrsleep)rr rrr r reffective_is_runningr, cur_intervalretriesexc slack_timetoe telegram_excr+s` ` @rnetwork_retry_loopr<,sX( }B7J%7,'T'& MM-,LG  # "$$B qLGE%@$L qLG -- - - -O  $ 8J LLA:sT^ &7L  MMCZQT UL    F S  S,'Q'K"7 > GU`!!> GU`!- 11s2s\?Q7RL S& qLG .s=F B B B FFF;F < FF B E?)C>F E?C-(F-+E?AE:4F:E??FF  F)__doc__rrcollections.abcrtypingrrtelegram._utils.loggingrtelegram.errorrrr r __name__r#strfloatEventr/intr<rrrrGs& %%.LL X  <@+//3l.Y'l.-$!678l. l.  l. ' l."d(+,l.l. l.r