o zqfã@s6ddlZddlmZddlmZmZGdd„dƒZdS)éN)Úsleep)ÚConnectionErrorÚ TimeoutErrorc@s:eZdZdZeeejffdd„Zde fdd„Z dd„Z d S) ÚRetryz0Retry a specific number of times after a failurecCs||_||_||_dS)a' Initialize a `Retry` object with a `Backoff` object that retries a maximum of `retries` times. `retries` can be negative to retry forever. You can specify the types of supported errors which trigger a retry with the `supported_errors` parameter. N)Ú_backoffÚ_retriesÚ_supported_errors)ÚselfÚbackoffÚretriesÚsupported_errors©r úJ/root/parts/websockify/install/lib/python3.10/site-packages/redis/retry.pyÚ__init__ s  zRetry.__init__Úspecified_errorscCstt|jt|ƒƒƒ|_dS)zM Updates the supported errors with the specified error types N)ÚtupleÚsetr)r rr r rÚupdate_supported_errorss ÿzRetry.update_supported_errorsc Cs†|j ¡d} z|ƒWS|jyA}z(|d7}||ƒ|jdkr)||jkr)|‚|j |¡}|dkr7t|ƒWYd}~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 rTéN)rÚresetrrÚcomputer)r ÚdoÚfailÚfailuresÚerrorr r r rÚcall_with_retry#s  €ùýzRetry.call_with_retryN) Ú__name__Ú __module__Ú __qualname__Ú__doc__rrÚsocketÚtimeoutrÚlistrrr r r rrs   ü r)r ÚtimerÚredis.exceptionsrrrr r r rÚs