dG VddlZddlZddlZddlZddlZddlZddlmZm 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<rddl=Z=dd+l'm>Z>dd,l m?Z?ej@d-ejA.ZBej@d/ZCejDd0eBd1eBfd2ZejDd3ejEd4ejEd1ejAeBgeBffd5Zd3ejEd4ejEd1ejFeBejAeBgeBfffd6ZGd7d8eGZHeIZJGd9d:ZKGd;dZNGd?d@eNZOeIZPdAejFejEeIfdBejEd1ejEfdCZQGdDdEeGZRGdFdGZSGdHdIeZTGdJdKeTZUGdLdMe jVZVGdNdOZWddPlXmYZYe;rddQlZm[Z[dSdS)RN)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_RetValTfnreturncdSN)r3s fC:\Users\ChattiNader\Documents\MyHotelMatch\api\dev\Lib\site-packages\pip/_vendor/tenacity/__init__.pyretryr9cDdargsdkwcdSr6r7)r<r=s r8r9r9hr:r;ctdkr2tdrtdSdtdtffd }|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 rrfr4ct|tr/tjd|jjd|jjdt |r ti}nYtrFttj dr,tj |r ti}n ti}||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 AsyncRetryingtornadohasattrgenrBTornadoRetryingRetryingwraps)r@rr<r=s r8wrapzretry..wrapxs!Z((  n 0DnnPQP[Pdnnn#1%% ,$15$@C$@$@ ,WW[2IJJ ,w{OpOpqrOsOs ,#U2c22e+s++771:: r;)lencallabler9r0)r<r=rPs`` r8r9r9msu 5zzQ8E!H--uwwuQx    I )        r;ceZdZdZdS)TryAgainz/Always retry the executed function when raised.N)rG __module__ __qualname____doc__r7r;r8rTrTs9999r;rTceZdZdS) DoAttemptNrGrUrVr7r;r8rYrYDr;rYceZdZdS)DoSleepNrZr7r;r8r]r]r[r;r]cteZdZUdZdZejeed<dZ ej eed<defdZ defdZ 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 r7 REPR_FIELDSNNAMEr4ctdfdjD}jjd|dS)Nz, c3BK|]}|dt|VdS)=N)getattr).0fieldselfs r8 z&BaseAction.__repr__..s;``eAAu)=)=AA``````r;())joinr`rFrG)rh state_strs` r8__repr__zBaseAction.__repr__sHII````tO_````` .)88I8888r;c t|Sr6)reprrhs r8__str__zBaseAction.__str__sDzzr;) rGrUrVrWr`tSequencestr__annotations__raOptionalrnrrr7r;r8r_r_s$&KC%%% D!*S/   9#9999r;r_c0eZdZdZdZdejddfdZdS) RetryActionrr9rr4Nc.t||_dSr6)floatr)rhrs r8__init__zRetryAction.__init__s5\\ r;)rGrUrVr`rars SupportsFloatr|r7r;r8ryrysBK D"ao"$""""""r;ryfirstsecondc|tur|n|Sr6)_unset)r~rs r8 _first_setrsf__66%/r;c8eZdZdZd fd Zd dZdefd ZxZS) RetryErrorz>Encapsulates the last attempt instance right before giving up. last_attemptFuturer4NcX||_t|dSr6)rsuperr|)rhrrFs r8r|zRetryError.__init__s)( &&&&&r; t.NoReturncP|jjr|j|r6)rfailedresultrqs r8reraisezRetryError.reraises*   # -#**,, , r;c0|jjd|jdS)N[])rFrGrrqs r8rrzRetryError.__str__s!.)@@D,=@@@@r;)rrr4N)r4r) rGrUrVrWr|rrurr __classcell__rFs@r8rrs{HH'''''' AAAAAAAAAr;rc eZdZdZd dZddZdejeje d eje d ejd deje fd Z dS)AttemptManagerzManage attempt context. retry_stateRetryCallStatec||_dSr6r)rhrs r8r|zAttemptManager.__init__s&r;r4NcdSr6r7rqs r8 __enter__zAttemptManager.__enter__s r;exc_type exc_value tracebacktypes.TracebackTypect|tr|j|||fdS|jddS)NT)rC BaseExceptionr set_exception set_result)rhrrrs r8__exit__zAttemptManager.__exit__sW i / /    * *Hi+K L L L4   ' ' - - -4r;)rrr4N) rGrUrVrWr|rrsrwTyperboolrr7r;r8rrs!!''''     *QVM23 :m, :34  D       r;rceZdZeeeeeedde 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 jffdZeeeeeeeeeef 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 jfefddfdZdefdZede jee jffdZdedefdZd dZdd de j e e!e jffdZ"de j#e$ddffdZ%e&de j de'fde jde jde'fdZ(dS)! BaseRetryingNFrstopr/waitr.r9beforerafter before_sleeprretry_error_clsretry_error_callbackc ||_||_||_||_||_||_||_||_tj |_ | |_ | |_ dSr6) rrrr9rrrr threadinglocal_localrr rhrrrr9rrrrrrs r8r|zBaseRetrying.__init__sb      ( o'' .$8!!!r;r4c |t||jt||jt||jt||jt||jt||jt||jt||j t| |j t| |j  S)z8Copy this object with some parameters changed if needed.) rrrr9rrrrrr) rFrrrrr9rrrrrrrs r8copyzBaseRetrying.copys~~UDJ//D$),,D$),,UDJ//fdk22UDJ//#L$2CDDw 55&8LMM!+,@$B[!\!\   r;cd|jjdt|dd|jd|jd|jd|jd|jd |jd S) N) rFrGidrrrr9rrrqs r8rnzBaseRetrying.__repr__s $' $ $bhh D $ $I $ $I $ $Z $ $Z  $ $ k  $ $ Z  $ $ $ r;cl |jjS#t$ri|j_|jjcYSwxYw)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 statisticsAttributeErrorrqs r8rzBaseRetrying.statistics$sH, *;) ) * * *%'DK ";) ) ) ) *s "33r@ctjdtjdtjdtjffd }dtjdtjdtffd }|_||_|S)z[Wrap a function for retrying. :param f: A function to wraps for retrying. argskwr4cg|Ri|Sr6r7)rrr@rhs r8 wrapped_fz%BaseRetrying.wraps..wrapped_fFs#4'D'''B'' 'r;kwargscDj|i|Sr6)rrN)rrr@rhs r8 retry_withz&BaseRetrying.wraps..retry_withJs(49d-f--33A66 6r;) functoolsrNrsAnyr0r9r)rhr@rrs`` r8rNzBaseRetrying.wraps@s    (QU (!% (AE ( ( ( ( ( (   ( 7ae 7qu 7 7 7 7 7 7 7 7 ) r;c|jtj|jd<d|jd<d|jd<dS)N start_timerattempt_numberridle_for)rcleartime monotonicrqs r8beginzBaseRetrying.beginRsI (,(8(8 %,-()&' ###r;rc|j}|*|j||tS|jjo+t |jt }|s*||s|S|j | ||j |j d<| |ra|j r| |S||}|jr||||jr||}nd}t#||_|xj|z c_|j dxx|z cc<|j dxxdz cc<|j||t+|S)Nrdelay_since_first_attemptrrr)outcomerrYrrC exceptionrTr9rrseconds_since_startrrrrrrry next_actionrrr])rhrfutis_explicit_retry retry_excrs r8iterzBaseRetrying.iterXs! ;{& K(((;; '/6p:kFYFcFcFeFego;p;p! TZZKZ%H%H ::<<  : ! JJ{ # # #7B7V34 999 - - 1( >00===,,S11I| *''))) 0 9 II+I66EEE"-e"4"4 %  ###u,### ()))Q.)))   (   k * * *u~~r;c#VK|t|ddi} ||}t|trt |VnAt|t r*|||ndS)Nr7)r3rrTr) rrrrCrYrr]prepare_for_next_attemptr)rhrdos r8__iter__zBaseRetrying.__iter__}s $TdBGGG  {33B"i(( $=======B(( 44666 2 r;r3.rrcdSr6r7)rhr3rrs r8__call__zBaseRetrying.__call__s r;r))rGrUrVrrr$r r)r+rrsCallableUnionintr{rrwrrrr|robjectrrurnpropertyDictrr0rNrrYr]r Generatorrrrr2rr7r;r8rrs:?&%IKK33557E6CIM.8RV99z173:./5699 9  9  ,-t34 9z+,d239j-=,>,D!EF99 +9 j5E4F4M)NO99996KQ-3-3-3HNGMZ`)/?Eci  wqz173:#6"7"=>FG gk6)* gk6)*  wz6)*   $4#5t#;>>--clnn=====>B(( 44666 2  sA330B&%B&N) rGrUrVrWrsrr2rrr7r;r8rMrMsZ1:c8m4QUaeX`r;rMc zeZdZdZdeddffd ZedefdZe dede j deddfd Z xZ S) rzDEncapsulates a (future or past) attempted call to a target function.rr4NcVt||_dSr6)rr|r)rhrrFs r8r|zFuture.__init__s' ,r;c.|duS)z8Return whether a exception is being held in this future.N)rrqs r8rz Future.faileds~~t++r;value has_exceptioncv||}|r||n|||S)zConstruct a new Future object.)rr)clsrrrrs r8 constructzFuture.constructsIc.!!  "   e $ $ $ $ NN5 ! ! ! r;)rGrUrVrWrr|rrr classmethodrsrrrrs@r8rrsNN-s-t------,,,,X,s15RZ[r;rc eZdZdZdedejedejdejddf dZ e deje fd Z dd Z d ejddfd Zd ejejeedfddfdZdZdS)rz5State related to a single call wrapped with Retrying.rr3rrr4Nctj|_||_||_||_||_d|_d|_d|_ d|_ d|_ dS)Nrr) rrrrr3rrrroutcome_timestamprr)rhrr3rrs r8r|zRetryCallState.__init__s^.**(  $%+/ 48" 48r;c2|jdS|j|jz Sr6)rrrqs r8rz"RetryCallState.seconds_since_starts  ! )4%77r;cPd|_d|_|xjdz c_d|_dSNr)rrrrrqs r8rz'RetryCallState.prepare_for_next_attempts3 !% q r;valctj}t|j}||||c|_|_dSr6)rrrrrrr)rhrtsrs r8rzRetryCallState.set_resultsH ^  T()) s/2B, d,,,r;rrctj}t|j}||d||c|_|_dSr)rrrrrrr)rhrrrs r8rzRetryCallState.set_exceptionsN ^  T()) (1+&&&/2B, d,,,r;c d|jd}nU|jjr-|j}d|jjd|d}nd|j}t t|jd}|jj}d|dt|d|j d |d |d S) Nznone yetzfailed ( rkz returned rz : attempt #z ; slept for z; last result: >) rrrrFrGrr{roundrrr)rhrrsleptclsnames r8rnzRetryCallState.__repr__s < FF \  9 ..00IK 3 <KKyKKKFF8!4!4!6!688FeDM1--...)r7rrRXXrr$2ErrSXrriorrrrr;r)rGrUrVrWrrsrwr0rr|rr{rrrTuplerrrrnr7r;r8rrs??9"9 Jy !9e 9  9  9999:8QZ%6888X8     7ae77777 7agaf].C]Ti.i&j7os7777 s s s s sr;r)rH)rL)\rrrrtypingrsrDabcrr concurrentrinspectrr9rr r r r r rrrrrrrrnaprrrrrrrrrrrr r!r"r#r$r%r&wait_full_jitterr'rr(r)rr*r+rr,r-rI TYPE_CHECKINGtypesr.r/TypeVarrr0r2overloadrr ExceptionrTr NO_RESULTrYr{r]r_ryrrrrrrMrrpip._vendor.tenacity._asynciorHpip._vendor.tenacity.tornadowebrLr7r;r8rs&  ########''''''%%%%%%******000000......&&&&&&""""""......------111111""""""%$$$$$""""""%%%%%%""""""######))))))======))))))"""""" +*****...... ? LLL AIk 4 4 4 19Z  i I      !%  !*i[)5K*L     !%!')QZ U^H^=_2_*`::::::y::: FHH              e   ("""""*""" 0agaeVm,0ae00000 A A A A A A A A 0i i i i i 3i i i X|.W^.CsCsCsCsCsCsCsCsL877777 @????????@@r;