*jm7 j S r SSKrSSKrSSKrSSKrSSKJr SSKJ r SSKJ
r
SSKJ r SSKJ r \ R r
\ R r\ R r\ R r\R" S-
r " S S
5 r\rS rS rS
rS rS rS rSS.S jr SSK r \ R& =rr g! \ a gf = f))Future wrap_futureisfuture N) GenericAlias ) base_futures)events)
exceptions)format_helpersc \ rS rSr\rSrSrSrSr Sr
Sr Sr Sr
SS.S jrS rS r\" \5 r\S 5 r\R, S 5 rS
rS rSS jrS
rS rS r S r S r SS.S jr S r S r!S r"S r#\#r$Sr%g)r NFloopc Uc [ R " 5 U l OXl / U l U R R 5 ( a0 [
R " [ R " S5 5 U l g g )Nr )
r get_event_loop_loop
_callbacks get_debugr
extract_stacksys _getframe_source_tracebackselfr s 6/opt/alt/python313/lib64/python3.13/asyncio/futures.py__init__Future.__init__H s\ < ..0DJ J :: ! !%3%A%A
a &"D " " c . [ R " U 5 $ N)r _future_reprr s r __repr__Future.__repr__X s ((..r c U R ( d g U R nU R R S3UU S.nU R ( a U R US' U R
R
U5 g )Nz exception was never retrieved)message exceptionfuturesource_traceback)_Future__log_traceback
_exception __class____name__r r call_exception_handler)r exccontexts r __del__Future.__del__[ sl ##
oo >>**++IJ
! !*.*@*@G& '
))'2r c U R $ r )r* r" s r _log_tracebackFuture._log_tracebackm s ###r c 6 U( a [ S5 eSU l g )Nz'_log_traceback can only be set to FalseF)
ValueErrorr* )r vals r r4 r5 q s FG G $ r c : U R nUc [ S5 eU$ )Nz!Future object is not initialized.)r RuntimeErrorr s r get_loopFuture.get_loopw s! zz < BC C r c U R b U R nS U l U$ U R c [ R " 5 nU$ [ R " U R 5 nU$ r )_cancelled_exc_cancel_messager
CancelledError)r r/ s r _make_cancelled_error Future._make_cancelled_error~ sf *%%C"&D J ' ++-C
++D,@,@AC
r c ~ SU l U R [ :w a g[ U l Xl U R 5 g)NFT)r* _state_PENDING
_CANCELLEDr? _Future__schedule_callbacks)r msgs r cancel
Future.cancel s7 % ;;( " " !!#r c U R S S nU( d g / U R S S & U H u p#U R R X US9 M! g Nr0 )r r call_soon)r callbackscallbackctxs r __schedule_callbacksFuture.__schedule_callbacks sI OOA& &MH JJ = 'r c ( U R [ :H $ r )rD rF r" s r cancelledFuture.cancelled s {{j((r c ( U R [ :g $ r )rD rE r" s r done Future.done s {{h&&r c ( U R [ :X a U R 5 eU R [ :w a [ R
" S5 eSU l U R b% U R R U R 5 eU R $ )NzResult is not ready.F) rD rF rA _FINISHEDr
InvalidStateErrorr* r+ with_traceback
_exception_tb_resultr" s r result
Future.result st ;;* $,,. . ;;) # ../EF F $ ?? &//001C1CD D||r c U R [ :X a U R 5 eU R [ :w a [ R
" S5 eSU l U R $ )NzException is not set.F)rD rF rA r[ r
r\ r* r+ r" s r r' Future.exception sO ;;* $,,. . ;;) # ../FG G $ r rM c U R [ :w a U R R XUS9 g Uc [ R
" 5 nU R R X45 g rL )rD rE r rN contextvars copy_contextr append)r fnr0 s r add_done_callbackFuture.add_done_callback sN ;;( " JJ 7 ;%224 OO " "B= 1r c U R VVs/ s H u p#X!:w d M X#4PM nnn[ U R 5 [ U5 -
nU( a X@R S S & U$ s snnf r )r len)r rh frQ filtered_callbacks
removed_counts r remove_done_callbackFuture.remove_done_callback sh /3oo *.=(1!" 'qh.= * DOO,s3E/FF
!3OOA
*s
A!A!c U R [ :w a& [ R " U R SU < 35 eXl [
U l U R
5 g )N: )rD rE r
r\ r_ r[ rG )r r` s r
set_resultFuture.set_result sH ;;( " ..$++ b/IJ J !!#r c ~ U R [ :w a& [ R " U R SU < 35 e[ U[
5 ( a U" 5 n[ U[ 5 ( a [ S5 nXl Xl UnXl
UR U l [ U l U R 5 SU l g )Nrs zPStopIteration interacts badly with generators and cannot be raised into a FutureT)rD rE r
r\
isinstancetype
StopIterationr: __cause__ __context__r+
__traceback__r^ r[ rG r* )r r' new_excs r
set_exceptionFuture.set_exception s ;;( " ..$++ b/IJ J i & &! I i / /" $, -G !* "+ I# & 4 4 !!# # r c # # U R 5 ( d SU l U v U R 5 ( d [ S5 eU R 5 $ 7f)NTz await wasn't used with future)rX _asyncio_future_blockingr: r` r" s r __await__Future.__await__ s@ yy{{,0D )Jyy{{ >? ?{{} s AA) __log_tracebackr r r? r> r+ r^ r r_ r rD r )&r-
__module__ __qualname____firstlineno__rE rD r_ r+ r r r? r> r r* r r# r1 classmethodr __class_getitem__propertyr4 setterr; rA rI rG rU rX r` r' ri rp rt r~ r __iter____static_attributes__ r r r r s ( FGJ E ON % O # " /3 $L1
$ $ % %
"
> ) '
04 2
$$. Hr r c ` U R nU" 5 $ ! [ a U R $ f = fr )r; AttributeErrorr )futr; s r _get_loopr * s: << z
99
s
--c R U R 5 ( a g U R U5 g r )rU rt )r r` s r _set_result_unless_cancelledr 6 s
}}NN6r c h [ U 5 nU[ R R L a6 [ R " U R
6 R
U R 5 $ U[ R R L a6 [ R " U R
6 R
U R 5 $ U $ r ) rx
concurrentfuturesr@ r
argsr] r| r\ )r/ exc_classs r _convert_future_excr = s S IJ&&555((#((3BB3CTCTUU j((:: :++SXX6EEcFWFWXX
r c UR 5 ( a U R " 5 U R " 5 ( d g UR 5 nUb U R " [ U5 5 g UR
5 nU R " U5 g r )rU rI set_running_or_notify_cancelr' r~ r r` rt )r sourcer' r` s r _set_concurrent_future_stater G sr 2 2 4 4 "I !4Y!?@ f%r c UR 5 ( a g U R 5 ( a UR 5 g U R 5 nUb UR [ U5 5 g U R 5 nUR
U5 g r )rU rI r' r~ r r` rt )r destr' r` s r _copy_future_stater V sk ~~
$$& 29 = >]]_F OOF #r c ^ ^^^^ [ T 5 ( d4 [ T [ R R 5 ( d [ S5 e[ T5 ( d4 [ T[ R R 5 ( d [ S5 e[ T 5 ( a [
T 5 OS m[ T5 ( a [
T5 OS mS mU U4S jnUUU4S jnTR U5 T R U5 g )Nz(A future is required for source argumentz-A future is required for destination argumentc R [ U 5 ( a [ X5 g [ X5 g r )r r r )r( others r
_set_state!_chain_future.._set_statez s F u - ( 7r c > U R 5 ( aH Tb T[ R " 5 L a TR 5 g TR TR 5 g g r )rU r _get_running_looprI call_soon_threadsafe) destinationr source_loops r _call_check_cancel)_chain_future.._call_check_cancel sH " ""kV5M5M5O&O
00 ? #r c > TR 5 ( a Tb TR 5 ( a g Tb T[ R " 5 L a
T" TU 5 g TR 5 ( a g TR TTU 5 g r )rU is_closedr r r )r r dest_loopr s r _call_set_state&_chain_future.._call_set_state sm ! ! # #%)*=*=*?*? V-E-E-G G {F +""$$ * *:{F Kr )r rw r r r TypeErrorr ri )r r r r r r r s `` @@@r
_chain_futurer j s F Jv/9/A/A/H/H%J %JBCC K K4>4F4F4M4M*O *OGHH'/'7'7)F#TK*2;*?*? +&TI8 @ L !!"45
_-r r c [ U 5 ( a U $ Uc [ R " 5 nUR 5 n[ X5 U$ r )r r r
create_futurer )r( r
new_futures r r r sC
|$$&##%J&% r ) __all__concurrent.futuresr re loggingr typesr r r r
r r rE rF r[ DEBUG STACK_DEBUGr _PyFuturer r r r r r r _asyncio_CFuture ImportErrorr r r r s
$
$
" " mma E ER
& $().X !%
(
!'FX s B) )B21B2