o <‘ðiÓ ã@sˆddlmZddlmZmZmZmZmZmZm Z m Z mZddlm Z mZmZddlmZe dƒZer8ddlmZGdd„deeƒZd S) é)Úsleep) Ú TYPE_CHECKINGÚAnyÚ AwaitableÚCallableÚOptionalÚTupleÚTypeÚTypeVarÚUnion)ÚConnectionErrorÚ RedisErrorÚTimeoutError)Ú AbstractRetryÚT)ÚAbstractBackoffcs²eZdZejZeeffdddedee e dff‡fdd„ Zded e fd d„Z ddegeefdeeegefeeegeffdeeege fde d ef dd„Z‡ZS)ÚRetryÚbackoffrÚretriesÚsupported_errors.cstƒ |||¡dS©N)ÚsuperÚ__init__)Úselfrrr©Ú __class__©úR/root/parts/websockify/install/lib/python3.10/site-packages/redis/asyncio/retry.pyrs zRetry.__init__ÚotherÚreturncCs:t|tƒstS|j|jko|j|jkot|jƒt|jƒkSr)Ú isinstancerÚNotImplementedÚ_backoffÚ_retriesÚsetÚ_supported_errors)rrrrrÚ__eq__%s ÿýzRetry.__eq__NFÚdoÚfailÚis_retryableÚwith_failure_countc Ãs¾|j ¡d} z|ƒIdHWS|jy]}z@|r ||ƒs ‚|d7}|r/|||ƒIdHn||ƒIdH|jdkrB||jkrB|‚|j |¡}|dkrSt|ƒIdHWYd}~nd}~wwq )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 ``is_retryable``: optional function to determine if an error is retryable ``with_failure_count``: if True, the failure count is passed to the failure handler rTNé)r"Úresetr%r#Úcomputer)rr'r(r)r*ÚfailuresÚerrorrrrrÚcall_with_retry/s*€ €òýzRetry.call_with_retry)NF)Ú__name__Ú __module__Ú__qualname__rÚ__hash__rrÚintrr r rrÚboolr&rrrrÚ Exceptionrr0Ú __classcell__rrrrrs<þüþýüøþÿÿýùø ÷rN)ÚasynciorÚtypingrrrrrrr r rÚredis.exceptionsrr rÚredis.retryrrÚ redis.backoffrrrrrrÚs,