a  zea@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 stjfi|||_dS)N)super__init__r )selfr r  __class__a/opt/bitninja-python-dojo/embedded/lib/python3.9/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|trpz||i|V}Wn tyb|tYq0| |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