Ë
|
|
çúh ã óà d dl Z d dlZd dlmZ d dlmZmZmZmZm Z m
|
Z
|
m Z m Z m Z d dlmZmZ e d« Z e ded¬« Zerd d lmZ G d
|
d ee e j, « Z G d d ee « Zy)é N)Úsleep) Ú TYPE_CHECKINGÚAnyÚCallableÚGenericÚIterableÚOptionalÚTupleÚTypeÚTypeVar)ÚConnectionErrorÚ TimeoutErrorÚTÚET)ÚboundÚ covariant)ÚAbstractBackoffc óÂ e Zd ZU dZeee df ed< dddedeee df fdZ e
|
j d e d
|
e fd « Zd
|
efd Zd eee d
|
dfdZd
|
efdZded
|
dfdZy)Ú AbstractRetryz0Retry a specific number of times after a failure.Ú_supported_errorsÚbackoffr ÚretriesÚsupported_errorsc ó. || _ || _ || _ y)a'
|
Initialize a `Retry` object with a `Backoff` object
|
that retries a maximum of `retries` times.
|
`retries` can be negative to retry forever.
|
You can specify the types of supported errors which trigger
|
a retry with the `supported_errors` parameter.
|
N)Ú_backoffÚ_retriesr )Úselfr r r s õ^ H:\项ç®\archive\æµè¯ç»\èæ¬\Change_password\venv_build\Lib\site-packages\redis/retry.pyÚ__init__zAbstractRetry.__init__ s ð Ø Ø!1Õ ó ÚotherÚreturnc ó t S ©N)ÚNotImplemented©r r! s r Ú__eq__zAbstractRetry.__eq__/ s ä Ð r c ól t | j | j t | j « f« S r$ )Úhashr r Ú frozensetr ©r s r Ú__hash__zAbstractRetry.__hash__3 s' ÜT]] D§M¡M´9¸T×=SÑ=SÓ3TÐUÓVÐVr Úspecified_errorsNc ób t t | j t |« z « « | _ y)zM
|
Updates the supported errors with the specified error types
|
N)ÚtupleÚsetr )r r- s r Úupdate_supported_errorsz%AbstractRetry.update_supported_errors6 s* ô "'Ü ×&Ñ&¬Ð/?Ó)@Ñ@Ó Aó"
|
Õ r c ó | j S )z,
|
Get the number of retries.
|
©r r+ s r Ú get_retrieszAbstractRetry.get_retries> s ð }}Ð r Úvaluec ó || _ y)z,
|
Set the number of retries.
|
Nr3 )r r5 s r Úupdate_retriesz AbstractRetry.update_retriesD s ð r )Ú__name__Ú
|
__module__Ú __qualname__Ú__doc__r
|
r r Ú__annotations__Úintr ÚabcÚabstractmethodr Úboolr' r, r r1 r4 r7 © r r r r s·
Ù:à T !W c\Ñ*Ó*ð2à"ð2ð ð2ð Q¡¨ Ñ-ó 2ð" ×Ñð Cð Dò ó ð ðW#ó Wð
|
¸ÀÀaÁÑ8Ið
|
Èdó
|
ð Só ð Cð ¨Dô r r c
|
óÆ e Zd Zej Zeeej ffddde de
|
e e df f fd Z dedefd Z dd
|
eg ef d ee gef d eee gef defd Z xZS )ÚRetryr r r r .c ó( t | |||« y r$ )Úsuperr )r r r r Ú __class__s r r zRetry.__init__N s ø ô Ñ 'Ð+;Õ<r r! r" c óð t |t « st S | j |j k( xrF | j |j k( xr+ t | j « t |j « k( S r$ )Ú
|
isinstancerC r% r r r0 r r& s r r' z Retry.__eq__Z sc Ü%¤Ô'Ü!Ð !ð MMU^^Ñ +ò LØ § ¡ Ñ/ò LäD×*Ñ*Ó+¬s°5×3JÑ3JÓ/KÑKð
|
r ÚdoÚfailÚ is_retryablec óL | j j « d} |« S # | j $ rm}|r ||« s |dz } ||« | j dk\ r|| j kD r|| j j |« }|dkD r t |« Y d}~nd}~ww xY w)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 rI rJ rK ÚfailuresÚerrorr s r Úcall_with_retryzRetry.call_with_retryd s ð ×ÑÔ ØØð #Ùt øØ×)Ñ)ò #Ù © °UÔ(;ØØA ÙU Ø== AÒ%¨(°T·]±]Ò*BØ KØ --×/Ñ/°Ó9ØQ;Ü'Nÿøð #úð s & ¦B"µA#B  B"r$ )r8 r9 r: r r, r r ÚsocketÚtimeoutr= r
|
r Ú Exceptionr r r@ r' r r r rR Ú __classcell__)rF s @r rC rC K sº ø Ø ×%Ñ%Hð Ø Ø NNð9
|
ñ
|
=à"ð
|
=ð ð
|
=ð Y¡°Ð 4Ñ5õ
|
=ð
|
Cð
|
Dó
|
ð ?Cñ #à RUOð#ð { CÐ'Ñ(ð#ð x¨¨ °TÐ(9Ñ :Ñ;ð #ð
|
|
÷ #r rC )r> rS Útimer Útypingr r r r r r r
|
r r Úredis.exceptionsr r r rU r Ú redis.backoffr ÚABCr rC rA r r ú<module>r\ sg ðÛ
|
Û Ý ÷
|
÷
|
õ
|
÷ ;á CLÙ Cy¨DÔ1áÝ-ô/ GAJ §¡ô / ôd3#M)Ñ $õ 3#r
|
