+ V@i Rt^RIt^RIHt^RIt^RIt^RIt^RIHt^RI t ^RI H t H t H t H t Ht] P!R4t!RR]4t]P&t]P&]3tRR lt!R R ]P,4t]!4tR R lt]!4tRRltRRltRRltRRlt] P@RRl4t!] P@RRl4t!RRlt!R#)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]tRt^*tRtR#)ReturnValueIgnoredErrorN)__name__ __module__ __qualname____firstlineno____static_attributes__r 4/usr/lib/python3/dist-packages/tornado/concurrent.pyr r *srr c0V^8dQhR\R\/#)xreturn)rbool)formats"r __annotate__r4s""""rc"\V\4#N) isinstanceFUTURES)rs&r is_futurer4s a !!rca]tRt^8toV3RlRlt]P R 8dR V3RlRlltRtVt R#R V3RlRlltRtVt R#) DummyExecutorcD<V^8dQhRS[RS[3,RS[RS[RR/#)rfn.argskwargsrfutures.Future[_T])rr r)r __classdict__s"rrDummyExecutor.__annotate__9s637#,/;> rc\P!4p\WA!V/VB4V# \d$\ T\ P !44T#i;ir)rFuture"future_set_result_unless_cancelled Exceptionfuture_set_exc_infosysexc_info)selfr#r$r%futures&&*, rsubmitDummyExecutor.submit9sV! 8 .vr47J67J K  8   7  8s**AAc*<V^8dQhRS[RS[RR/#)rwaitcancel_futuresrNr)rr's"rrr(Es"   d t rcR#rr )r0r5r6s&&&rshutdownDummyExecutor.shutdownE rc$<V^8dQhRS[RR/#)rr5rNr7)rr's"rrr(Js    rcR#rr )r0r5s&&rr9r:Jr;rr N) )TF)T) r rrrr2r. version_infor9r__classdictcell__)r's@rr!r!8s= 6!       rr!c<V^8dQhR\R\R\/#)rr$r%r)rr)rs"rrrQs!=%=%3=%#=%(=%rcaRV3RllpV'dS'd \R4h\V4^8XdV!V^,4#\V4^8wd\R\V44hV#)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. cJV^8dQhR\R\R\3,/#)rr#r.)rr*)rs"rr%run_on_executor..__annotate__|s#  h 8CK3H rcv<aaSPRR4o\P!S4RVV3Rll4pV#)executorcHV^8dQhR\R\R\R\/#)rr0r$r%r)rr*)rs"rrHrun_on_executor..run_on_executor_decorator..__annotate__s(  # c S V rct<\4p\VS4P!SV.VO5/VBp\WC4V#r)r*getattrr2 chain_future)r0r$r% async_future conc_futurerGr#s&*, rwrapperCrun_on_executor..run_on_executor_decorator..wrappers;!8L!$188TSDSFSK  3 r)get functoolswraps)r#rOrGr%sf @rrun_on_executor_decorator2run_on_executor..run_on_executor_decorator|s:::j*5      rz*cannot combine positional and keyword argszexpected 1 argument, got %d) ValueErrorlen)r$r%rTs*l rrun_on_executorrXQs^V   EFF 4yA~(a11 Ta6D BB $$rcPV^8dQhR\R,R\R,RR/#)rabrN) Future[_T]r&)r)rs"rrrs2"-"- /0"- /0"- "-rcaRV3Rllp\V\4'd\W4R#^RIHpVP 4P W4R#)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`. c V^8dQhRRRR/#)rrZr\rNr )rs"rr"chain_future..__annotate__s ) ) ) )rcD<SP4'dR#\VR4'd/VP4e\SVP44R#VP 4pVeSP V4R#SP VP44R#)Nr/)donehasattrr/r- exception set_exception set_resultresult)rZa_excr[s& rcopychain_future..copysh 6688  1j ! !ajjl&> 1::< 0KKME & QXXZ(r)IOLoopN)rr*future_add_done_callbacktornado.iolooprjcurrent add_future)rZr[rhrjs&f rrLrLs> ) )!V ) *##A,rc,V^8dQhRRR\RR/#)rr1%Union[futures.Future[_T], Future[_T]]valuerN)r )rs"rrrs$ ! ! 3 !<> !  !rcXVP4'gVPV4R#R#)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) cancelledre)r1rqs&&rr+r+s&     %  rc,V^8dQhRRR\RR/#)rr1rpexcrN) BaseException)rs"rrrs)LL 3L:GL LrcVP4'gVPV4R#\P!RVR7R#)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)rsrdrerror)r1rus&&r%future_set_exception_unless_cancelledrys0     S! rc@V^8dQhRRR\R.R3,RR/#)rr1r&callbackNrr)rs"rrrs2   ,46J5KT5Q,R   rcR#rr r1rs&&rrkrk rc@V^8dQhRRR\R.R3,RR/#)rr1r\rNrr)rs"rrrs0   $,l^T-A$B   rcR#rr rs&&rrkrkrrc:V^8dQhRRR\R,RR/#)rr1rprNr).Nr)rs"rrrs)++ 3+?G ?R+ +rchVP4'd V!V4R#VPV4R#)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)raadd_done_callbackrs&&rrkrks%{{}}  *r)"__doc__asyncio concurrentrrRr.r| tornado.logrtypingrrrrrTypeVarr r,r r*rrExecutorr!dummy_executorrXobject _NO_RESULTrLr+ryr-overloadrkr rrrs   88 ^^D i  >>6 ""G$$,=%@X "-J !L,?0    +r