Ë
|
|
çúhX ã ó d dl mZ d dlmZmZmZmZmZmZm Z d dl
|
m Z m Z m Z d dlmZ e d« Zerd dlmZ G d dee « Zy )
|
é )Úsleep)Ú TYPE_CHECKINGÚAnyÚ AwaitableÚCallableÚTupleÚTypeÚTypeVar)ÚConnectionErrorÚ
|
RedisErrorÚ TimeoutError)Ú AbstractRetryÚT)ÚAbstractBackoffc ó e Zd Zej Zeeffdddedee e
|
df f fd Z de de fd Zd
|
eg ee f d ee
|
ge f defd Z xZS ) ÚRetryÚbackoffr ÚretriesÚsupported_errors.c ó( t | |||« y ©N)ÚsuperÚ__init__)Úselfr r r Ú __class__s õf H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/asyncio/retry.pyr zRetry.__init__ s ø ô Ñ 'Ð+;Õ<ó ÚotherÚreturnc óð t |t « st S | j |j k( xrF | j |j k( xr+ t | j « t |j « k( S r )Ú
|
isinstancer ÚNotImplementedÚ_backoffÚ_retriesÚsetÚ_supported_errors)r r s r Ú__eq__z Retry.__eq__ sc Ü%¤Ô'Ü!Ð !ð MMU^^Ñ +ò LØ § ¡ Ñ/ò LäD×*Ñ*Ó+¬s°5×3JÑ3JÓ/KÑKð
|
r ÚdoÚfailc óv K | j j « d} |« d{ S 7 # | j $ rt}|dz } ||« d{ 7 | j dk\ r|| j kD r|| j j |« }|dkD rt |« d{ 7 Y d}~nd}~ww xY ww)a&
|
Execute an operation that might fail and returns its result, or
|
raise the exception that was thrown depending on the `Backoff` object.
|
`do`: the operation to call. Expects no argument.
|
`fail`: the failure handler, expects the last error that was thrown
|
r Né )r# Úresetr& r$ Úcomputer )r r( r) ÚfailuresÚerrorr s r Úcall_with_retryzRetry.call_with_retry% s§ è ø ð ×ÑÔ ØØð )Ù TzÐ!zùØ×)Ñ)ò )ØA Ù5k×!Ñ!Ø== AÒ%¨(°T·]±]Ò*BØ KØ --×/Ñ/°Ó9ØQ;Ü .×(Ñ(ÿøð )úð ùsP B9¡
|
2 «0¬2 ¯B9°2 ²B5ÁB0ÁAÁAB0Â%B(Â&B0Â+B9Â0B5Â5B9)Ú__name__Ú
|
__module__Ú __qualname__r Ú__hash__r r Úintr r r r r Úboolr' r r r r0 Ú __classcell__)r s @r r r s ø Ø ×%Ñ%Hð Ø ð:
|
ñ =à"ð =ð ð =ð ZÑ 0°#Ð 5Ñ6õ =ð
|
Cð
|
Dó
|
ð)Ø2y¨|Ð+Ñ,ð)Ø4<¸j¸\È3Ð=NÑ4Oð)à
|
÷)r r N)Úasyncior Útypingr r r r r r r
|
Úredis.exceptionsr r r Ú redis.retryr r Ú redis.backoffr r © r r ú<module>r> s: ðÝ ß P× PÑ Pç FÑ FÝ %á CLáÝ-ô-)M*Ñ %õ -)r
|
