o 6Wj@sddlZddlZddlmZddlmZejrddlmZGdddeZejeej dgej e ffZ Gdd d eZ Gd d d eZGd d d eZGdddeZdS)N)_utils) retry_base)RetryCallStatec@speZdZdZejdddefddZ    dd d Z    dd d Z    dddZ    dddZ dS)async_retry_basez/Abstract base class for async retry strategies. retry_staterreturncsdSNselfrr r e/home/esfera/Documents/content_generation/venv/lib/python3.10/site-packages/tenacity/asyncio/retry.py__call__szasync_retry_base.__call__other*typing.Union[retry_base, async_retry_base] retry_allcC t||Srrr rr r r __and__! zasync_retry_base.__and__cC t||Srrrr r r __rand__&rzasync_retry_base.__rand__ retry_anycCrrrrr r r __or__+rzasync_retry_base.__or__cCrrrrr r r __ror__0rzasync_retry_base.__ror__N)rrrr)rrrr) __name__ __module__ __qualname____doc__abcabstractmethodboolr rrrrr r r r rs0   rrc@sFeZdZdZdejegejefddfddZ dddefd d Z dS) retry_if_exceptionzARetry strategy that retries if an exception verifies a predicate. predicaterNcC ||_dSrr$r r$r r r __init__>rzretry_if_exception.__init__rrcsJ|jdur td|jjr#|j}|durtd||IdHSdS)N(__call__() called before outcome was setz(outcome failed but the exception is NoneF)outcome RuntimeErrorfailed exceptionr$)r rr-r r r r Cs  zretry_if_exception.__call__) rrrrtypingCallable BaseException Awaitabler"r(r r r r r r#;s r#c@sHeZdZdZdejejgejefddfddZ dddefd d Z dS) retry_if_resultz+Retries if the result verifies a predicate.r$rNcCr%rr&r'r r r r(Srzretry_if_result.__init__rrcs6|jdur td|jjs||jIdHSdS)Nr)F)r*r+r,r$resultr r r r r Xs  zretry_if_result.__call__) rrrrr.r/Anyr1r"r(r r r r r r2Ps r2c@>eZdZdZdejeefddfddZddde fd d Z dS) rz1Retries if any of the retries condition is valid.retriesrNcGr%rr6r r6r r r r(e zretry_any.__init__rrcs8d}|jD]}|pt||IdH}|r|Sq|S)NFr6rwrap_to_async_funcr rr3rr r r r h zretry_any.__call__ rrrrr.Unionrrr(r"r r r r r rbrc@r5) rz/Retries if all the retries condition are valid.r6rNcGr%rr7r8r r r r(tr9zretry_all.__init__rrcs8d}|jD]}|ot||IdH}|s|Sq|S)NTr:r<r r r r wr>zretry_all.__call__r?r r r r rqrAr)r r.tenacityrr TYPE_CHECKINGrrr@r/r1r" RetryBaseTr#r2rrr r r r s