ó P'—^c@sddlmZmZddlZddlZddlmZmZmZmZddl m Z m Z m Z m Z mZdddd d d d d dddddddddgZed„Zdd„Zd„ZyddlmZWn'ek rd efd„ƒYZnXyddlmZWn'ek rMd efd„ƒYZnXed„ƒZe eddd „ƒZd!„Zd"„Zdefd#„ƒYZed$„Ze d%„ƒZ e e!ƒZ"de"_#d&e"_$e d'„ƒZ%d(„Z&e&ƒZ'd)e'_$d*„Z(e d+„ƒZ)dS(,iĸĸĸĸ(tdatetimet timedeltaNi(tmaptranget raise_fromtHashable(t decoratortwrapst get_argnamest arggettertcontextmanagertraisertignoretsilenttsuppresst nullcontexttreraisetretrytfallbacktlimit_error_ratetErrorRateExceededtpost_processingt collectingtjoiningtoncetonce_pert once_per_argst wrap_withcs‡‡‡fd†}|S(sbConstructs function that raises the given exception with given arguments on any invocation.cs(ˆs ˆrˆˆˆŽ‚nˆ‚dS(N((tatkw(targstexception_or_classtkwargs(s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyt_raisers ((RRR R!((RRR s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR scs"tˆƒ‰‡‡fd†}|S(sBAlters function to ignore given errors, returning default instead.cs%tˆƒ‡‡‡fd†ƒ}|S(Ncs*yˆ||ŽSWnˆk r%ˆSXdS(N((RR (tdefaultterrorstfunc(s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pytwrapper$s (R(R$R%(R"R#(R$s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR#s!(t_ensure_exceptable(R#R"R((R"R#s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR s cCsttƒ|ƒS(s)Alters function to ignore all exceptions.(R t Exception(R$((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR -s(RcBs)eZdZd„Zd„Zd„ZRS(sķContext manager to suppress specified exceptions After the exception is suppressed, execution proceeds with the next statement following the with statement. cGs ||_dS(N(t _exceptions(tselft exceptions((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyt__init__<scCsdS(N((R)((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyt __enter__?scCs|dk ot||jƒS(N(tNonet issubclassR((R)texctypetexcinsttexctb((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyt__exit__Bs (t__name__t __module__t__doc__R+R,R2(((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR5s  (RcBs,eZdZdd„Zd„Zd„ZRS(sgContext manager that does no additional processing. Used as a stand-in for a normal context manager, when a particular block of code is only sometimes used with a normal context manager: cm = optional_cm if condition else nullcontext() with cm: # Perform operation, using optional_cm if condition is True cCs ||_dS(N(t enter_result(R)R6((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR+^scCs|jS(N(R6(R)((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR,ascGsdS(N((R)texcinfo((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR2dsN(R3R4R5R-R+R,R2(((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRSs   ccs<t|ƒ}y dVWn |k r7}t||ƒnXdS(s#Reraises errors as other exception.N(R&R(R#tintote((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRhs   icCsķt|ƒ}xĢt|ƒD]•}y |ƒSWq|k r­}|dkpQ||ƒsZ‚n|d|krp‚qŪt|ƒrˆ||ƒn|}|dkrŪtj|ƒqŪqXqWdS(s›Makes decorated function retry up to tries times. Retries only on specified errors. Sleeps timeout or timeout(attempt) seconds between tries.iiN(R&RR-tcallablettimetsleep(tcallttriesR#ttimeoutt filter_errorstattemptR9t timeout_value((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRrs   cGsdx]|D]U}t|ƒr%|tfn|\}}t|ƒ}y |ƒSWq|k r[qXqWdS(siTries several approaches until one works. Each approach has a form of (callable, expected_errors).N(R:R'R&(t approachestapproachR$tcatch((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRˆs $   cCs2t|tƒot|tƒ}|r(|St|ƒS(skEnsures that errors are passable to except clause. I.e. should be BaseException subclass or a tuple.(t isinstancettypeR.t BaseExceptionttuple(R#t is_exception((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR&“scBseZRS((R3R4(((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRšscs:tˆtƒr!tdˆƒ‰n‡‡‡fd†}|S(s…If function fails to complete fails times in a row, calls to it will be intercepted for timeout with exception raised instead.tsecondscs:dˆ_dˆ_tˆƒ‡‡‡‡fd†ƒ}|S(Nics˜ˆjr7tjƒˆjˆkr+ˆ‚q7dˆ_nyˆ||Ž}Wn:ˆjd7_ˆjˆkr€tjƒˆ_n‚nXdˆ_|SdS(Nii(tblockedRtnowR-tfails(RR tresult(t exceptionRNR$R?(s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR%§s    (RNR-RLR(R$R%(RPRNR?(R$s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRĢs  $(RFtintR(RNR?RPR((RPRNR?s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRscCs ||ƒƒS(s3Post processes decorated function result with func.((R=R$((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRŋss4Transforms a generator into list returning function.cCs|jt|j|ƒƒƒS(s*Joins decorated function results with sep.(tjoinRt __class__(R=tsep((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRČscs‡fd†}|S(sECall function only once for every combination of the given arguments.csXtjƒ‰tƒ‰tƒ‰tˆƒ‰tˆƒ‡‡‡‡‡‡fd†ƒ}|S(Ncsˆˆ|t‡‡‡fd†ˆDƒƒ}t|tƒrKˆˆj}}nˆˆj}}||kr~||ƒˆˆˆŽSWdQXdS(Nc3s!|]}ˆ|ˆˆƒVqdS(N((t.0tname(Rtget_argR (s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pys Üs(RIRFRtaddtappend(RR tvaluestdoneRX(targnamest done_listtdone_setR$RWtlock(RR s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyR%Ųs"  (t threadingtLocktsettlistR R(R$R%(R\(R]R^R$RWR_s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRŌs     * ((R\R((R\s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRÐss5Let function execute once, noop all subsequent calls.cCstt|ƒŒ|ƒS(sDCall function once for every combination of values of its arguments.(RR(R$((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRëscCs| |ƒSWdQXdS(s%Turn context manager into a decoratorN((R=tctx((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pyRðs(*RRR;R`tcompatRRRRt decoratorsRRRR R t__all__R'R R-R R t contextlibRt ImportErrortobjectRRRRR&RRRRcRR3R5RRRRR(((s,/tmp/pip-unpacked-wheel-WgnHs6/funcy/flow.pytsJ  "(          "