]j rSrSSKrSSKJr SSKrSSKrSSKrSSKJr SSK r SSK J r J r J r J r Jr \ R"S5r"SS\5r\R&r\R&\4rS \ S \4S jr"S S \R.5r\"5rS\ S\ S \ 4Sjr\"5rS\SS\SS S4SjrSSS\S S4SjrSSS\S S4Sjr SSS\ \ \!\ \\ \RD4S S4Sjr#\ RHSSS\ S/S4S S4Sj5r%\ RHSS S\ S /S4S S4S!j5r%SSS\ S"S S4S#jr%g)$aUtilities for working with ``Future`` objects. Tornado previously provided its own ``Future`` class, but now uses `asyncio.Future`. This module contains utility functions for working with `asyncio.Future` in a way that is backwards-compatible with Tornado's old ``Future`` implementation. While this module is an important part of Tornado's internal implementation, applications rarely need to interact with it directly. N)futures)app_log)AnyCallableOptionalTupleUnion_Tc\rSrSrSrg)ReturnValueIgnoredError*N)__name__ __module__ __qualname____firstlineno____static_attributes__rO/home/mande/repo/quber/.venv/lib/python3.13/site-packages/tornado/concurrent.pyr r *srr xreturnc"[U[5$N) isinstanceFUTURES)rs r is_futurer4s a !!rc\rSrSrS\S\4S\S\SS4Sjr\RS :aSS \ S \ SS 4S jjr Sr g SS \ SS 4Sjjr Sr g ) DummyExecutor8fn.argskwargsrfutures.Future[_T]c[R"5n[XA"U0UD65 U$![a# [ U[ R "55 U$f=fr)rFuture"future_set_result_unless_cancelled Exceptionfuture_set_exc_infosysexc_info)selfr r!r"futures rsubmitDummyExecutor.submit9sV! 8 .vr47J67J K  8   7  8s*)AA) waitcancel_futuresNcgrr)r+r1r2s rshutdownDummyExecutor.shutdownE rcgrr)r+r1s rr4r5Jr6rr)TF)T) rrrrrr rr-r) version_infoboolr4rrrrrr8sw37#,/;>  6!  d t       rrr!r"c^S[S[S[44U4SjjnU(aT(a [S5e[U5S:Xa U"US5$[U5S:wa[S[U55eU$) aDecorator to run a synchronous method asynchronously on an executor. Returns a future. The executor to be used is determined by the ``executor`` attributes of ``self``. To use a different attribute name, pass a keyword argument to the decorator:: @run_on_executor(executor='_thread_pool') def foo(self): pass This decorator should not be confused with the similarly-named `.IOLoop.run_in_executor`. In general, using ``run_in_executor`` when *calling* a blocking method is recommended instead of using this decorator when *defining* a method. If compatibility with older versions of Tornado is required, consider defining an executor and using ``executor.submit()`` at the call site. .. versionchanged:: 4.2 Added keyword arguments to use alternative attributes. .. versionchanged:: 5.0 Always uses the current IOLoop instead of ``self.io_loop``. .. versionchanged:: 5.1 Returns a `.Future` compatible with ``await`` instead of a `concurrent.futures.Future`. .. deprecated:: 5.1 The ``callback`` argument is deprecated and will be removed in 6.0. The decorator itself is discouraged in new code but will not be removed in 6.0. .. versionchanged:: 6.0 The ``callback`` argument was removed. r r.c >^^TRSS5m[R"T5S[S[S[S[4UU4Sjj5nU$)Nexecutorr+r!r"rct>[5n[UT5R"TU/UQ70UD6n[XC5 U$r)r%getattrr- chain_future)r+r!r" async_future conc_futurer<r s rwrapperCrun_on_executor..run_on_executor_decorator..wrappers;!8L!$188TSDSFSK  3 r)get functoolswrapsrr%)r rBr<r"s` @rrun_on_executor_decorator2run_on_executor..run_on_executor_decorator|sQ::j*5   # c S V   rz*cannot combine positional and keyword argsrzexpected 1 argument, got %d)rr% ValueErrorlen)r!r"rGs ` rrun_on_executorrLQspV h 8CK3H  EFF 4yA~(a11 Ta6D BB $$ra) Future[_T]r#bc^SU4Sjjn[U[5(a [X5 gSSKJn UR 5R X5 g)aRChain two futures together so that when one completes, so does the other. The result (success or failure) of ``a`` will be copied to ``b``, unless ``b`` has already been completed or cancelled by the time ``a`` finishes. .. versionchanged:: 5.0 Now accepts both Tornado/asyncio `Future` objects and `concurrent.futures.Future`. Nc4>TR5(ag[US5(a,UR5b[TUR55 gUR 5nUbTR U5 gTR UR55 g)Nr*)donehasattrr*r( exception set_exception set_resultresult)rMa_excrOs rcopychain_future..copysh 6688  1j ! !ajjl&> 1::< 0KKME & QXXZ(rr)IOLoop)rMrNrN)rr%future_add_done_callbacktornado.ioloopr[current add_future)rMrOrYr[s ` rr?r?s9 )!V ) *##A,rr,z%Union[futures.Future[_T], Future[_T]]valuecRUR5(dURU5 gg)zSet the given ``value`` as the `Future`'s result, if not cancelled. Avoids ``asyncio.InvalidStateError`` when calling ``set_result()`` on a cancelled `asyncio.Future`. .. versionadded:: 5.0 N) cancelledrV)r,r`s rr&r&s&     %  rexcc|UR5(dURU5 g[R"SUS9 g)aSet the given ``exc`` as the `Future`'s exception. If the Future is already canceled, logs the exception instead. If this logging is not desired, the caller should explicitly check the state of the Future and call ``Future.set_exception`` instead of this wrapper. Avoids ``asyncio.InvalidStateError`` when calling ``set_exception()`` on a cancelled `asyncio.Future`. .. versionadded:: 6.0 z$Exception after Future was cancelled)r*N)rbrUrerror)r,rcs r%future_set_exception_unless_cancelledrfs0     S! rr#callbackcgrrr,rhs rr\r\ rrNcgrrrjs rr\r\rkr).NcbUR5(a U"U5 gURU5 g)a4Arrange to call ``callback`` when ``future`` is complete. ``callback`` is invoked with one argument, the ``future``. If ``future`` is already done, ``callback`` is invoked immediately. This may differ from the behavior of ``Future.add_done_callback``, which makes no such guarantee. .. versionadded:: 5.0 N)rRadd_done_callbackrjs rr\r\s%{{}}  *r)&__doc__asyncio concurrentrrEr)types tornado.logrtypingrrrrr TypeVarr r'r r%rr9rExecutorrdummy_executorrLobject _NO_RESULTr?r& BaseExceptionrftype TracebackTyper(overloadr\rrrr~s   88 ^^D i  >>6 """"G$$,=%3=%#=%(=%@X "- /0"- /0"- "-J ! 3 !<> !  !L 3L:GL L,? 3?/%:M:M1NN?  ?0  ,46J5KT5Q,R      $,l^T-A$B    + 3+?G ?R+ +r