Ë
|
ñúh"V ã ó8 d dl mZ d dlZd dlZd dlZd dlZd dlZd dlmZ d dl m
|
Z
|
ddl m Z m Z mZmZmZmZmZ ddlmZ ej* e« Z edg d ¢« Z e« Z G d
|
d e« Z ej: e « G d d e« « Z e d« e _ y)é )Úabsolute_importN)Ú
|
namedtuple)Ú takewhileé )ÚConnectTimeoutErrorÚ InvalidHeaderÚ MaxRetryErrorÚ ProtocolErrorÚ
|
ProxyErrorÚReadTimeoutErrorÚ ResponseError)ÚsixÚRequestHistory)ÚmethodÚurlÚerrorÚstatusÚredirect_locationc ó¨ e Zd Zed « Zej
|
d « Zed « Zej
|
d « Zed « Zej
|
d « Zy)Ú
|
_RetryMetac óN t j dt « | j S ©Nz}Using 'Retry.DEFAULT_METHOD_WHITELIST' is deprecated and will be removed in v2.0. Use 'Retry.DEFAULT_ALLOWED_METHODS' instead©ÚwarningsÚwarnÚDeprecationWarningÚDEFAULT_ALLOWED_METHODS©Úclss úQH:\Change_password\venv_build\Lib\site-packages\pip/_vendor/urllib3/util/retry.pyÚDEFAULT_METHOD_WHITELISTz#_RetryMeta.DEFAULT_METHOD_WHITELIST$ s% ä ð Sä ô
|
ð
|
×*Ñ*Ð*ó c óF t j dt « || _ y r r ©r Úvalues r r! z#_RetryMeta.DEFAULT_METHOD_WHITELIST- s! ä ð Sä ô
|
ð
|
',Õ#r" c óN t j dt « | j S ©NzUsing 'Retry.DEFAULT_REDIRECT_HEADERS_BLACKLIST' is deprecated and will be removed in v2.0. Use 'Retry.DEFAULT_REMOVE_HEADERS_ON_REDIRECT' instead©r r r Ú"DEFAULT_REMOVE_HEADERS_ON_REDIRECTr s r Ú"DEFAULT_REDIRECT_HEADERS_BLACKLISTz-_RetryMeta.DEFAULT_REDIRECT_HEADERS_BLACKLIST6 s% ä ð ^ä ô
|
ð
|
×5Ñ5Ð5r" c óF t j dt « || _ y r' r( r$ s r r* z-_RetryMeta.DEFAULT_REDIRECT_HEADERS_BLACKLIST? s! ä ð ^ä ô
|
ð
|
27Õ.r" c óN t j dt « | j S ©NzlUsing 'Retry.BACKOFF_MAX' is deprecated and will be removed in v2.0. Use 'Retry.DEFAULT_BACKOFF_MAX' instead©r r r ÚDEFAULT_BACKOFF_MAXr s r Ú BACKOFF_MAXz_RetryMeta.BACKOFF_MAXH s% ä ð Oä ô
|
ð
|
×&Ñ&Ð&r" c óF t j dt « || _ y r- r. r$ s r r0 z_RetryMeta.BACKOFF_MAXQ s! ä ð Oä ô
|
ð
|
#(Õ r" N)Ú__name__Ú
|
__module__Ú __qualname__Úpropertyr! Úsetterr* r0 © r" r r r # s Ø ñ+ó ð+ð ×$Ñ$ñ,ó %ð,ð ñ6ó ð6ð (×.Ñ.ñ7ó /ð7ð ñ'ó ð'ð ×Ññ(ó ñ(r" r c ó e Zd ZdZ eg d¢« Z eg d¢« Z eg d¢« ZdZdddddde ddd d dd e e fd
|
Z
|
d Z e dd « Z d Zd Zd Zd dZd Zd dZd Zd Zd Zd dZd Z d dZd Z fdZ xZ S ) ÚRetryaJ Retry configuration.
|
|
Each retry attempt will create a new Retry object with updated values, so
|
they can be safely reused.
|
|
Retries can be defined as a default for a pool::
|
|
retries = Retry(connect=5, read=2, redirect=5)
|
http = PoolManager(retries=retries)
|
response = http.request('GET', 'http://example.com/')
|
|
Or per-request (which overrides the default for the pool)::
|
|
response = http.request('GET', 'http://example.com/', retries=Retry(10))
|
|
Retries can be disabled by passing ``False``::
|
|
response = http.request('GET', 'http://example.com/', retries=False)
|
|
Errors will be wrapped in :class:`~urllib3.exceptions.MaxRetryError` unless
|
retries are disabled, in which case the causing exception will be raised.
|
|
:param int total:
|
Total number of retries to allow. Takes precedence over other counts.
|
|
Set to ``None`` to remove this constraint and fall back on other
|
counts.
|
|
Set to ``0`` to fail on the first retry.
|
|
Set to ``False`` to disable and imply ``raise_on_redirect=False``.
|
|
:param int connect:
|
How many connection-related errors to retry on.
|
|
These are errors raised before the request is sent to the remote server,
|
which we assume has not triggered the server to process the request.
|
|
Set to ``0`` to fail on the first retry of this type.
|
|
:param int read:
|
How many times to retry on read errors.
|
|
These errors are raised after the request was sent to the server, so the
|
request may have side-effects.
|
|
Set to ``0`` to fail on the first retry of this type.
|
|
:param int redirect:
|
How many redirects to perform. Limit this to avoid infinite redirect
|
loops.
|
|
A redirect is a HTTP response with a status code 301, 302, 303, 307 or
|
308.
|
|
Set to ``0`` to fail on the first retry of this type.
|
|
Set to ``False`` to disable and imply ``raise_on_redirect=False``.
|
|
:param int status:
|
How many times to retry on bad status codes.
|
|
These are retries made on responses, where status code matches
|
``status_forcelist``.
|
|
Set to ``0`` to fail on the first retry of this type.
|
|
:param int other:
|
How many times to retry on other errors.
|
|
Other errors are errors that are not connect, read, redirect or status errors.
|
These errors might be raised after the request was sent to the server, so the
|
request might have side-effects.
|
|
Set to ``0`` to fail on the first retry of this type.
|
|
If ``total`` is not set, it's a good idea to set this to 0 to account
|
for unexpected edge cases and avoid infinite retry loops.
|
|
:param iterable allowed_methods:
|
Set of uppercased HTTP method verbs that we should retry on.
|
|
By default, we only retry on methods which are considered to be
|
idempotent (multiple requests with the same parameters end with the
|
same state). See :attr:`Retry.DEFAULT_ALLOWED_METHODS`.
|
|
Set to a ``False`` value to retry on any verb.
|
|
.. warning::
|
|
Previously this parameter was named ``method_whitelist``, that
|
usage is deprecated in v1.26.0 and will be removed in v2.0.
|
|
:param iterable status_forcelist:
|
A set of integer HTTP status codes that we should force a retry on.
|
A retry is initiated if the request method is in ``allowed_methods``
|
and the response status code is in ``status_forcelist``.
|
|
By default, this is disabled with ``None``.
|
|
:param float backoff_factor:
|
A backoff factor to apply between attempts after the second try
|
(most errors are resolved immediately by a second try without a
|
delay). urllib3 will sleep for::
|
|
{backoff factor} * (2 ** ({number of total retries} - 1))
|
|
seconds. If the backoff_factor is 0.1, then :func:`.sleep` will sleep
|
for [0.0s, 0.2s, 0.4s, ...] between retries. It will never be longer
|
than :attr:`Retry.DEFAULT_BACKOFF_MAX`.
|
|
By default, backoff is disabled (set to 0).
|
|
:param bool raise_on_redirect: Whether, if the number of redirects is
|
exhausted, to raise a MaxRetryError, or to return a response with a
|
response code in the 3xx range.
|
|
:param bool raise_on_status: Similar meaning to ``raise_on_redirect``:
|
whether we should raise an exception, or return a response,
|
if status falls in ``status_forcelist`` range and retries have
|
been exhausted.
|
|
:param tuple history: The history of the request encountered during
|
each call to :meth:`~Retry.increment`. The list is in the order
|
the requests occurred. Each list item is of class :class:`RequestHistory`.
|
|
:param bool respect_retry_after_header:
|
Whether to respect Retry-After header on status codes defined as
|
:attr:`Retry.RETRY_AFTER_STATUS_CODES` or not.
|
|
:param iterable remove_headers_on_redirect:
|
Sequence of headers to remove from the request when a response
|
indicating a redirect is returned before firing off the redirected
|
request.
|
)ÚHEADÚGETÚPUTÚDELETEÚOPTIONSÚTRACE)i i i÷ )ÚCookieÚ AuthorizationzProxy-Authorizationéx é
|
Nr Tc ó& |t ur1|t ur t d« t j dt d¬« |}|t u r | j
|
}|t u r | j }|| _ || _ || _ || _
|
|| _ |du s|du rd}d}
|
|| _ |xs
|
t « | _ || _ | | _ |
|
| _ | | _ | xs
|
t' « | _ | | _ t- |D cg c] }|j/ « c}« | _ y c c}w )NzoUsing both 'allowed_methods' and 'method_whitelist' together is not allowed. Instead only use 'allowed_methods'úlUsing 'method_whitelist' with Retry is deprecated and will be removed in v2.0. Use 'allowed_methods' insteadr )Ú
|
stacklevelFr )Ú_DefaultÚ
|
ValueErrorr r r r r) ÚtotalÚconnectÚreadr ÚotherÚredirectÚsetÚstatus_forcelistÚallowed_methodsÚbackoff_factorÚraise_on_redirectÚraise_on_statusÚtupleÚhistoryÚrespect_retry_after_headerÚ frozensetÚlowerÚremove_headers_on_redirect)ÚselfrI rJ rK rM r rL rP rO rQ rR rS rU rV rY Úmethod_whitelistÚhs r Ú__init__zRetry.__init__õ s ð( ¤8Ñ +Ø ¤hÑ.Ü ð9óð ô
|
MMðIä"Ø õ ð /OØ hÑ &Ø "× :Ñ :OØ %¬Ñ 1Ø)-×)PÑ)PÐ &à
|
Ø Ø Ø Ø
|
à uÑ ¨¡ØHØ %Ð à Ø 0Ò 9´C³EÔ Ø .Ô Ø ,ÔØ!2Ô Ø .Ô Ø Ò)¤%£' Ø*DÔ'Ü*3Ø :Ö ;1QWWYÒ ;ó+
|
Õ'ùÚ ;s Ã*Dc ó t | j | j | j | j | j
|
| j | j | j | j | j | j | j | j ¬« }d|vrKd|vrGd| j v r*t j dt" « | j$ |d< n| j$ |d< |j' |« t) | « di |¤S )N) rI rJ rK rM r rL rO rQ rR rS rU rY rV r[ rP rE r7 )ÚdictrI rJ rK rM r rL rO rQ rR rS rU rY rV Ú__dict__r r r rP ÚupdateÚtype)rZ ÚkwÚparamss r Únewz Retry.new2 sê ÜØ**ØLLØØ]]Ø;;Ø**Ø !× 2Ñ 2Ø ×.Ñ.Ø "× 4Ñ 4Ø × 0Ñ 0ØLLØ'+×'FÑ'FØ'+×'FÑ'Fô
|
ð* RÑ 'Ð,=ÀRÑ,GØ! T§]¡]Ñ2Ü ðMä&ôð
|
.2×-AÑ-AÐ)Ò*à,0×,@Ñ,@Ð(Ñ)à bÔØtDzÑ#FÑ#Ð#r" c ó® |||n | j }t |t « r|S t |« xr d} | ||¬« }t j d||« |S )z3Backwards-compatibility for the old retries format.N)rM z!Converted retries value: %r -> %r)ÚDEFAULTÚ
|
isinstancer9 ÚboolÚlogÚdebug)r ÚretriesrM ÚdefaultÚ new_retriess r Úfrom_intzRetry.from_intV sY ð ?Ø!(Ð!4g¸#¿+¹+Gä guÔ %ØNä>Ò* dÙ'¨HÔ5 Ü Ð5°wÀ ÔLØÐr" c
|
óÈ t t t d t | j « « « « }|dk ry| j
|
d|dz
|
z z }t | j |« S )zIFormula for computing the current backoff
|
|
:rtype: float
|
c ó | j d u S ©N)r )Úxs r ú<lambda>z(Retry.get_backoff_time.<locals>.<lambda>l s A×$7Ñ$7¸4Ð$? r" é r r )ÚlenÚlistr ÚreversedrU rQ Úminr/ )rZ Úconsecutive_errors_lenÚ backoff_values r Úget_backoff_timezRetry.get_backoff_timed sf ô "%Ü ÜÑ?ÄÈ$Ï,É,ÓAWÓXó ó"
|
Ð ð
|
" QÒ &Øà ×+Ñ+¨qÐ5KÈaÑ5OÑ/PÑQ Ü4×+Ñ+¨]Ó;Ð;r" c óH t j d|« r t |« }nxt j j |« }|t d|z « |d |d d dz |dd z }t j j |« }|t j « z
|
}|dk rd}|S )Nz^\s*[0-9]+\s*$z Invalid Retry-After header: %sé )r rC r ) ÚreÚmatchÚintÚemailÚutilsÚ parsedate_tzr Ú mktime_tzÚtime)rZ Ú retry_afterÚsecondsÚretry_date_tupleÚ
|
retry_dates r Úparse_retry_afterzRetry.parse_retry_afteru s« ä 88Ð% {Ô 3Ü+Ó&Gä ${{× 7Ñ 7¸ Ó DÐ Ø Ð'Ü#Ð$DÀ{Ñ$RÓSÐSØ Ñ"Ð*ð
|
$4°B°QÐ#7¸$Ñ#>ÐAQÐRTÐRUÐAVÑ#VÐ ä ×.Ñ.Ð/?Ó@JØ ¤4§9¡9£;Ñ.Gà Q;ØGàr" c ó` |j j d« }|y| j |« S )z(Get the value of Retry-After in seconds.z Retry-AfterN)ÚheadersÚgetr ©rZ Úresponser s r Úget_retry_afterzRetry.get_retry_after s4 ð ×&Ñ&×*Ñ*¨=Ó9 à Ð Øà×%Ñ% kÓ2Ð2r" c óV | j |« }|rt j |« yy)NTF)r r Úsleepr s r Úsleep_for_retryzRetry.sleep_for_retry s' Ø×*Ñ*¨8Ó4 Ù Ü JJ{Ô #Øàr" c óZ | j « }|dk ry t j |« y )Nr )r| r r )rZ Úbackoffs r Ú_sleep_backoffzRetry._sleep_backoff s& Ø×'Ñ'Ó)Ø a<Ø Ü
|
|
7Õr" c óh | j r|r| j |« }|ry| j « y)aB Sleep between retry attempts.
|
|
This method will respect a server's ``Retry-After`` response header
|
and sleep the duration of the time requested. If that is not present, it
|
will use an exponential backoff. By default, the backoff factor is 0 and
|
this method will return immediately.
|
N)rV r r )rZ r Úslepts r r z Retry.sleep¤ s1 ð × *Ò *©xØ×(Ñ(¨Ó2EÙØà ×ÑÕ r" c óZ t |t « r |j }t |t « S )zzErrors when we're fairly sure that the server did not receive the
|
request, so it should be safe to retry.
|
)rh r Úoriginal_errorr ©rZ Úerrs r Ú_is_connection_errorzRetry._is_connection_error´ s' ô c:Ô &Ø×$Ñ$CÜ#Ô 2Ó3Ð3r" c ó. t |t t f« S )zErrors that occur after the request has been started, so we should
|
assume that the server began processing it.
|
)rh r r
|
r s r Ú_is_read_errorzRetry._is_read_error¼ s ô #Ô 0´-Ð @ÓAÐAr" c ó° d| j v r't j dt « | j }n | j
|
}|r|j « |vryy)zyChecks if a given HTTP method should be retried upon, depending if
|
it is included in the allowed_methods
|
r[ rE FT)r` r r r r[ rP Úupper)rZ r rP s r Ú_is_method_retryablezRetry._is_method_retryable sS ð § ¡ Ñ .Ü MMðIä"ô ð
|
#× 3Ñ 3Oà "× 2Ñ 2Oá v||~°_Ñ DØØr" c ó¸ | j |« sy| j r|| j v ry| j xr | j xr |xr || j v S )aw Is this method/status code retryable? (Based on allowlists and control
|
variables such as the number of total retries to allow, whether to
|
respect the Retry-After header, whether this header is present, and
|
whether the returned status code is on the list of status codes to
|
be retried upon on the presence of the aforementioned header)
|
FT)r£ rO rI rV ÚRETRY_AFTER_STATUS_CODES)rZ r Ú status_codeÚhas_retry_afters r Úis_retryzRetry.is_retryÖ sg ð ×(Ñ(¨Ô0Øà × Ò [°D×4IÑ4IÑ%IØð JJò ?Ø×/Ñ/ò ?à ò ?ð × =Ñ =Ð=ð
|
r" c óÖ | j | j | j | j | j | j
|
f}t t d|« « }|syt |« dk S )zAre we out of retries?NFr ) rI rJ rK rM r rL rw Úfilterry )rZ Ú retry_countss r Ú is_exhaustedzRetry.is_exhaustedê s^ ð JJØ LLØ IIØ MMØ KKØ JJð
|
ô F 4¨ Ó 6Ó7 ÙØä<Ó 1Ñ$Ð$r" c óT | j du r"|r t j t |« ||« | j }||dz }| j }| j
|
} | j }
|
| j } | j } d} d}d}|r=| j |« r,|du r t j t |« ||« |ó|dz }ní|rN| j |« r=| du s| j |« s t j t |« ||« | £| dz } n|r| | dz } n|r6|j « r&|
|
|
|
dz }
|
d} |j « }|j }n[t j } |rI|j r=| | dz } t j j! |j ¬« } |j }| j" t% |||||« fz }| j' ||| |
|
| | |¬« }|j) « rt+ |||xs t | « « t, j/ d||« |S ) a Return a new Retry object with incremented retry counters.
|
|
:param response: A response object, or None, if the server did not
|
return a response.
|
:type response: :class:`~urllib3.response.HTTPResponse`
|
:param Exception error: An error encountered during the request, or
|
None if the response was received successfully.
|
|
:return: A new ``Retry`` object.
|
FNru Úunknownztoo many redirects)r¦ )rI rJ rK rM r rL rU z$Incremented Retry for (url='%s'): %r)rI r Úreraiserb rJ rK rM r rL r r r£ Úget_redirect_locationr Ú GENERIC_ERRORÚSPECIFIC_ERRORÚformatrU r re r¬ r rj rk )rZ r r r r Ú_poolÚ _stacktracerI rJ rK rM Ú status_countrL Úcauser r rU Ú new_retrys r Ú incrementzRetry.incrementú s* ð& ::Ñ ¡5ä++d 5k¨5°+Ó>Ð >à
|
|
Ø Ð Ø QJEà,,ØyyØ==Ø{{ Ø
|
|
ØØØ Ðá T×.Ñ.¨uÔ5à%Ñ Ükk¤$ u£+¨u°kÓBÐBØÐ$Ø1 á t×*Ñ*¨5Ô1àu} D×$=Ñ$=¸fÔ$EÜkk¤$ u£+¨u°kÓBÐBØÐ!Ø á àÐ Ø
|
á (×8Ñ8Ô:àÐ#ØA Ø(EØ (× >Ñ >Ó @Ð Ø __Fô
|
"×/Ñ/EÙHOOØ Ð+Ø AÑ%LÜ%×4Ñ4×;Ñ;ÈÏÉÐ;ÓXØ! à,,Ü 6 3¨¨vÐ7HÓ Ið"
|
ñ
|
ð HHØØØØ Ø ØØð ó
|
ð × !Ñ !Ô #Ü s¨EÒ,I´]À5Ó5IÓJÐ Jä Ð8¸#¸yÔIàÐr" c ó: dj t | « | ¬« S )Nz|{cls.__name__}(total={self.total}, connect={self.connect}, read={self.read}, redirect={self.redirect}, status={self.status}))r rZ )r³ rb )rZ s r Ú__repr__zRetry.__repr__X s ð Pç
|
&T$Z d&Ó
|
+ð ,r" c óÎ |dk( r&t j dt « | j S t t t | « |« S # t $ r t t |« cY S w xY w)Nr[ rE )r r r rP ÚgetattrÚsuperr9 ÚAttributeError)rZ ÚitemÚ __class__s r Ú __getattr__zRetry.__getattr__^ sd ø Ø Ð%Ò %ä MMðIä"ô ð
|
×'Ñ'Ð 'ð (Ü5¤¨Ó-¨tÓ4Ð 4øÜ ò (Ü5 $Ó'Ò 'ð (ús ®A ÁA$Á#A$)TNrr )F)NNNNNN) r2 r3 r4 Ú__doc__rW r r¥ r) r/ rG r] re Ú classmethodro r| r r r r r r r r£ r¨ r¬ r¹ r» rÂ Ú __classcell__)rÁ s @r r9 r9 [ sð ø ñFñR (Ú<ó Ðñ
|
)ª Ó 9Ð ñ *3Ú:ó*Ð&ð
|
Ðð ØØ ØØØØ Ø ØØ Ø ØØ#'Ø#+à!ó#;
|
òz"$ðH ò ó ð ò<ò"ò.3óò ó ò 4òBò ó(
|
ò(%ð$ Ø ØØØØó\ò|,÷ (ð (r" r9 é ) Ú
|
__future__r r Úloggingr r r Ú collectionsr Ú itertoolsr Ú
|
exceptionsr r r r
|
r r r Úpackagesr Ú getLoggerr2 rj r ÚobjectrG rb r Ú add_metaclassr9 rg r7 r" r ú<module>rÐ s¤ ðÝ &ã Û Û Û Û Ý "Ý ÷÷ ñ õ àg×ÑÓ!ñ ØÒOóñ 8ô5(ô 5(ðp ×Ñ:Ó ôN(Fó N(ó ðN(ñd a
r"
|
