U ʗRea@s|ddlZddlZddlmZddlmZddlmZddlmZddlmZej r^ddl m Z e dZ Gd d d eZdS) N) BaseRetrying) DoAttempt)DoSleep)RetryCallState)gen)Future_RetValTcsLeZdZejfdejddfdd Zejdejejddd d Z Z S) TornadoRetryingz&typing.Callable[[float], Future[None]]N)sleepkwargsreturnc stjf|||_dS)N)super__init__r )selfr r  __class__/builddir/build/BUILDROOT/alt-python38-pip-22.2.1-2.el8.x86_64/opt/alt/python38/lib/python3.8/site-packages/pip/_vendor/tenacity/tornadoweb.pyr szTornadoRetrying.__init__zhtyping.Callable[..., typing.Union[typing.Generator[typing.Any, typing.Any, _RetValT], Future[_RetValT]]]z2typing.Generator[typing.Any, typing.Any, _RetValT])fnargsr r cos|t||||d}|j|d}t|trnz|||V}Wn"tk r`|tYqX| |qt|t r| | |Vqt |qdS)N) retry_objectrrr ) retry_state)beginriter isinstancer BaseException set_exceptionsysexc_info set_resultrprepare_for_next_attemptr rReturn)rrrr rdoresultrrr__call__$s    zTornadoRetrying.__call__) __name__ __module__ __qualname__rr typingAnyr coroutiner$ __classcell__rrrrr sr )rr(pip._vendor.tenacityrrrrtornador TYPE_CHECKINGZtornado.concurrentrTypeVarrr rrrrs