o a+)hG @sddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z ddlmZddlmZddlmZdd lmZdd lmZdd lmZdd lmZdd lmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddlmZddl m!Z!ddl m"Z"ddl m#Z#ddl m$Z$ddl m%Z%ddl m&Z&ddl'm(Z(ddl'm)Z)ddl'm*Z*ddl'm+Z+dd l'm,Z,dd!l'm-Z-dd"l'm.Z.dd#l'm/Z/dd#l'm/Z0dd$l'm1Z1dd%l2m3Z3dd&l2m4Z4dd'l5m6Z6dd(l5m7Z7dd)l8m9Z9dd*l8m:Z:dZ;ej<r&ddl=Z=dd+l'm>Z>dd,l m?Z?ej@d-ejAd.ZBe@d/ZCejDd0eBd1eBfd2d3ZejDd4ejEd5ejEd1ejAeBgeBffd6d3Zd4ejEd5ejEd1ejFeBejAeBgeBfffd7d3ZGd8d9d9eGZHeIZJGd:d;d;ZKGdd?d?ZNGd@dAdAeNZOeIZPdBejFejEeIfdCejEd1ejEfdDdEZQGdFdGdGeGZRGdHdIdIZSGdJdKdKeZTGdLdMdMeTZUGdNdOdOe jVZVGdPdQdQZWddRlXmYZYe;rddSlZm[Z[dSdS)TN)ABCabstractmethod)futures)iscoroutinefunction) retry_base) retry_all) retry_always) retry_any)retry_if_exception)retry_if_exception_type)retry_if_exception_cause_type)retry_if_not_exception_type)retry_if_not_result)retry_if_result) retry_never)retry_unless_exception_type)retry_if_exception_message)retry_if_not_exception_messagesleep)sleep_using_event)stop_after_attempt)stop_after_delay)stop_all)stop_any) stop_never)stop_when_event_set) wait_chain) wait_combine)wait_exponential) wait_fixed)wait_incrementing) wait_none) wait_random)wait_random_exponential)wait_exponential_jitter) before_log)before_nothing) after_log) after_nothing)before_sleep_log)before_sleep_nothing) wait_base) stop_base WrappedFn)bound_RetValTfnreturncCdSN)r2r6r6\C:\Users\User\Downloads\Proyecto_IoT\venv\Lib\site-packages\pip/_vendor/tenacity/__init__.pyretrycr8dargsdkwcOr4r5r6r:r;r6r6r7r8hr9csBtdkrtdrtdSdtdtffdd }|S)zWrap a function with a new `Retrying` object. :param dargs: positional arguments passed to Retrying object :param dkw: keyword arguments passed to the Retrying object rrfr3cst|trtd|jjd|jjdt|r!ti}ntr7t tj dr7tj |r7t i}nt i}||S)NzGot retry_base instance (zQ) as callable argument, this will probably hang indefinitely (did you mean retry=z(...)?)is_coroutine_function) isinstancerwarningswarn __class____name__r AsyncRetryingtornadohasattrgenr>TornadoRetryingRetryingwraps)r=rr<r6r7wrapxs   zretry..wrap)lencallabler8r/)r:r;rLr6r<r7r8msc@seZdZdZdS)TryAgainz/Always retry the executed function when raised.N)rC __module__ __qualname____doc__r6r6r6r7rOsrOc@ eZdZdS) DoAttemptNrCrPrQr6r6r6r7rTrTc@rS)DoSleepNrUr6r6r6r7rWrVrWc@sReZdZUdZdZejeed<dZ ej eed<defddZ defd d Z dS) BaseActiona5Base class for representing actions to take by retry object. Concrete implementations must define: - __init__: to initialize all necessary fields - REPR_FIELDS: class variable specifying attributes to include in repr(self) - NAME: for identification in retry object methods and callbacks r6 REPR_FIELDSNNAMEr3cs.dfddjD}jjd|dS)Nz, c3s$|] }|dt|VqdS)=N)getattr).0fieldselfr6r7 s"z&BaseAction.__repr__..())joinrYrBrC)r` state_strr6r_r7__repr__szBaseAction.__repr__cCst|Sr5)reprr_r6r6r7__str__szBaseAction.__str__) rCrPrQrRrYtSequencestr__annotations__rZOptionalrfrhr6r6r6r7rXs rXc@s(eZdZdZdZdejddfddZdS) RetryActionrr8rr3NcCst||_dSr5)floatr)r`rr6r6r7__init__szRetryAction.__init__)rCrPrQrYrZri SupportsFloatrpr6r6r6r7rnsrnfirstsecondcCs|tur|S|Sr5)_unset)rrrsr6r6r7 _first_setsrucs:eZdZdZd fdd Zdd d Zdefd d ZZS) RetryErrorz>Encapsulates the last attempt instance right before giving up. last_attemptFuturer3Ncs||_t|dSr5)rwsuperrp)r`rwrBr6r7rpszRetryError.__init__ t.NoReturncCs|jjr |j|r5)rwfailedresultr_r6r6r7reraises zRetryError.reraisecCs|jjd|jdS)N[])rBrCrwr_r6r6r7rhzRetryError.__str__)rwrxr3N)r3r{) rCrPrQrRrpr~rkrh __classcell__r6r6rzr7rvs  rvc @s\eZdZdZdddZddd Zd ejeje d eje d ejd deje fddZ dS)AttemptManagerzManage attempt context. retry_stateRetryCallStatecCs ||_dSr5r)r`rr6r6r7rps zAttemptManager.__init__r3NcCr4r5r6r_r6r6r7 __enter__szAttemptManager.__enter__exc_type exc_value tracebacktypes.TracebackTypecCs0t|tr|j|||fdS|jddS)NT)r? BaseExceptionr set_exception set_result)r`rrrr6r6r7__exit__s  zAttemptManager.__exit__)rrr3N) rCrPrQrRrprrirmTyperboolrr6r6r6r7rs  rc@sjeZdZeeeeeedde df de j e j e efgdfddddded e j d gdfd e j d gdfd e je j d gdfd ede je de je j d ge jffddZeeeeeeeeeef de j e j e j e efgdfefde j defde j defde j eefd e j e j d gdfefd e j e j d gdfefd e j e je j d gdfefd e j eefde j e je efde j e je j d ge jfefddfddZdefddZede jee jffddZdedefddZd)ddZdd de j e e!e jffdd Z"de j#e$ddffd!d"Z%e&d#e j d$e'fd%e jd&e jde'fd'd(Z(dS)* BaseRetryingNFrstopr.waitr-r8beforerafter before_sleepr~retry_error_clsretry_error_callbackc CsJ||_||_||_||_||_||_||_||_t |_ | |_ | |_ dSr5) rrrr8rrrr~ threadinglocal_localrr r`rrrr8rrrr~rrr6r6r7rps   zBaseRetrying.__init__r3c Csn|jt||jt||jt||jt||jt||jt||jt||jt||j t| |j t| |j d S)z8Copy this object with some parameters changed if needed.) rrrr8rrrr~rr) rBrurrrr8rrrr~rrrr6r6r7copys          zBaseRetrying.copycCsLd|jjdt|dd|jd|jd|jd|jd|jd |jd S) N) rBrCidrrrr8rrr_r6r6r7rfszBaseRetrying.__repr__cCs.z|jjWStyi|j_|jjYSw)aSReturn a dictionary of runtime statistics. This dictionary will be empty when the controller has never been ran. When it is running or has ran previously it should have (but may not) have useful and/or informational keys and values when running is underway and/or completed. .. warning:: The keys in this dictionary **should** be some what stable (not changing), but there existence **may** change between major releases as new statistics are gathered or removed so before accessing keys ensure that they actually exist and handle when they do not. .. note:: The values in this dictionary are local to the thread running call (so if multiple threads share the same retrying object - either directly or indirectly) they will each have there own view of statistics they have collected (in the future we may provide a way to aggregate the various statistics from each thread). )r statisticsAttributeErrorr_r6r6r7r$s    zBaseRetrying.statisticsr=cs\tdtjdtjdtjffdd }dtjdtjdtffdd }|_||_|S) z[Wrap a function for retrying. :param f: A function to wraps for retrying. argskwr3csg|Ri|Sr5r6)rrr=r`r6r7 wrapped_fFsz%BaseRetrying.wraps..wrapped_fkwargscsj|i|Sr5)rrJ)rrrr6r7 retry_withJrz&BaseRetrying.wraps..retry_with) functoolsrJriAnyr/r8r)r`r=rrr6rr7rJ@s $ zBaseRetrying.wrapscCs0|jt|jd<d|jd<d|jd<dS)N start_timerattempt_numberridle_for)rcleartime monotonicr_r6r6r7beginRs  zBaseRetrying.beginrcCs&|j}|dur|jdur||tS|jjot|jt}|s,|j|ds,|S|j dur6| ||j |j d<|j |dr[|j rJ| |S||}|jrV||||jre|j|d}nd}t||_|j|7_|j d|7<|j dd7<|jdur||t|S)Nrdelay_since_first_attemptrrr)outcomerrTr|r? exceptionrOr8r}rseconds_since_startrrrrr~rrn next_actionrrrW)r`rfutis_explicit_retry retry_excrr6r6r7iterXs8            zBaseRetrying.iterccsd|t|ddid} |j|d}t|tr t|dVnt|tr/|||ndSq)Nr6)r2rrTr) rrrr?rTrrWprepare_for_next_attemptr)r`rdor6r6r7__iter__}s    zBaseRetrying.__iter__r2.rrcOr4r5r6)r`r2rrr6r6r7__call__r9zBaseRetrying.__call__r))rCrPrQrrr#r r(r*rvriCallableUnionintrorrmrrrrprtobjectrrkrfpropertyDictrr/rJrrTrWr Generatorrrrr1rr6r6r6r7rs   "          %.rc@s8eZdZdZdejdefdejdejdefddZd S) rIzRetrying controller.r2.rrr3cOs|t||||d} |j|d}t|tr8z ||i|}Wnty1|tYnw| |nt|t rG| | |n|Sq )N) retry_objectr2rrTr) rrrr?rTrrsysexc_inforrWrr)r`r2rrrrr}r6r6r7rs       zRetrying.__call__N) rCrPrQrRrirr1rrr6r6r6r7rIs,rIc s\eZdZdZdeddffdd ZedefddZe ded e j d eddfd d Z Z S) rxzDEncapsulates a (future or past) attempted call to a target function.rr3Ncst||_dSr5)ryrpr)r`rrzr6r7rps  zFuture.__init__cCs |duS)z8Return whether a exception is being held in this future.N)rr_r6r6r7r|s z Future.failedvalue has_exceptioncCs(||}|r |||S|||S)zConstruct a new Future object.)rr)clsrrrrr6r6r7 constructs   zFuture.construct)rCrPrQrRrrprrr| classmethodrirrrr6r6rzr7rxs&rxc @seZdZdZdedejedejdejddf dd Z e deje fd d Z dd d Z dejddfddZdejejeedfddfddZddZdS)rz5State related to a single call wrapped with Retrying.rr2rrr3NcCsDt|_||_||_||_||_d|_d|_d|_ d|_ d|_ dS)Nrr) rrrrr2rrrroutcome_timestamprr)r`rr2rrr6r6r7rps  zRetryCallState.__init__cCs|jdurdS|j|jSr5)rrr_r6r6r7rs  z"RetryCallState.seconds_since_startcCs$d|_d|_|jd7_d|_dSNr)rrrrr_r6r6r7rs z'RetryCallState.prepare_for_next_attemptvalcCs.t}t|j}|||||_|_dSr5)rrrxrrrr)r`rtsrr6r6r7rs  zRetryCallState.set_resultrrcCs2t}t|j}||d|||_|_dSr)rrrxrrrr)r`rrrr6r6r7rs zRetryCallState.set_exceptionc Cs|jdurd}n|jjr|j}d|jjd|d}nd|j}tt|jd}|jj}d|dt |d|j d |d |d S) Nznone yetzfailed ( rcz returned rz : attempt #z ; slept for z; last result: >) rr|rrBrCr}roroundrrr)r`r}rsleptclsnamer6r6r7rfs  *zRetryCallState.__repr__r)rCrPrQrRrrirmr/rrprrorrrTuplerrrrfr6r6r6r7rs&  $ r)rD)rH)\rrrrtypingrir@abcrr concurrentrinspectrr8rrr r r r r rrrrrrrnaprrrrrrrrrrrrr r!r"r#r$r%wait_full_jitterr&rr'r(rr)r*rr+r,rE TYPE_CHECKINGtypesr-r.TypeVarrr/r1overloadrr ExceptionrOr NO_RESULTrTrorWrXrnrtrurvrrrIrxrpip._vendor.tenacity._asynciorDZpip._vendor.tenacity.tornadowebrHr6r6r6r7s                                           (0&- F