GSrSSKrSSKrSSKJr SSKrSSKr\Rr Sr Sr \R(aRSSK r \ Rr\\RR R"\RR R$/rO@\RR R"\RR R$/rSr"SS\5r"S S \R.5rg) zHThis package facilitates retries for HTTP/REST requests to the registry.N)nestedg?cB[Hn[X5(dM g g)NTF)RETRYABLE_EXCEPTION_TYPES isinstance)errexception_types 5lib/third_party/containerregistry/transport/retry_.py ShouldRetryr *s1n#&& 2 c<\rSrSrSrSrSrSrSrSr Sr S r g ) Factory2z'A factory for creating RetryTransports.c(0Ul[UlgN)kwargs!DEFAULT_SOURCE_TRANSPORT_CALLABLEsource_transport_callableselfs r __init__Factory.__init__5sDK%FD"r cXlU$r)r)rrs r WithSourceTransportCallable#Factory.WithSourceTransportCallable9s %>" Kr c"XRS'U$)N max_retriesr)rrs r WithMaxRetriesFactory.WithMaxRetries=s!,KK  Kr c"XRS'U$)Nbackoff_factorr)rr"s r WithBackoffFactorFactory.WithBackoffFactorAs$2KK ! Kr c"XRS'U$)Nshould_retry_fnr)rr&s r WithShouldRetryFunctionFactory.WithShouldRetryFunctionEs%4KK!" Kr cJ[UR540URD6$)z;Returns a RetryTransport constructed with the given values.)RetryTransportrrrs r Build Factory.BuildIs $88: Jdkk JJr )rrN) __name__ __module__ __qualname____firstlineno____doc__rrrr#r'r+__static_attributes__r r rr2s%/GKr rc<^\rSrSrSr\\\4U4SjjrSr Sr U=r $)r*NzEA wrapper for the given transport which automatically retries errors.cP>[[U] U5 X lX0lX@lgr)superr*r _max_retries_backoff_factor _should_retry)rsource_transportrr"r& __class__s r rRetryTransport.__init__Qs'  .$()9:#)(r cBSnURR"U0UD6$![asnX0R:dUR U5(de[ R "SU5 US- n[R"URSU--5 SnAMSnAff=f)aaDoes the request, exponentially backing off and retrying as appropriate. Backoff is backoff_factor * (2 ^ (retry #)) seconds. Args: *args: The sequence of positional arguments to forward to the source transport. **kwargs: The keyword arguments to forward to the source transport. Returns: The response of the HTTP request, and its contents. rzRetrying after exception %s.rN) r;request Exceptionr8r:loggingerrortimesleepr9)rargsrretriesrs r r@RetryTransport.request[sG  $$,,d=f==  '' 't/A/A#/F/F  4c:1  4''1g:67s! BA(BB)r9r8r:) r-r.r/r0r1DEFAULT_MAX_RETRIESDEFAULT_BACKOFF_FACTORr rr@r2 __classcell__)r<s@r r*r*Ns M1 6!, )r r*)r1rBrDcontainerregistry.transportrhttplib2six.moves.http_clientsixHttprrIrJPY3builtinsBrokenPipeErrormoves http_clientIncompleteReadResponseNotReadyrr objectrNestedTransportr*r3r r rZsO .$,MM!77,,/ ii** ii,, ii** ii,, KfK8$V++$r