Z7Gd?d@e7ej&Z8GdAdBe7ej&Z9GdCdDej&Z:GdEdFej&Z;GdGdHej&ZdSdS)KzTests for tasks.py.N)mock) GenericAlias) coroutines)futures)tasks)utils)support)assert_python_okc.tjddSN)asyncioset_event_loop_policy3/usr/lib/python3.11/test/test_asyncio/test_tasks.pytearDownModulers !$'''''rc KdSr rrrrcoroutine_functionrs DrFc |rd|z}nd|z}|%|d}d|d|d|d|dd |d  Sd|d|d|d S) Nz%sz %s, definedzcoro= created at r:>r)qualnamestatesrcsource_traceback generatorframes rformat_coroutiner #s&u %# $88UUUCCCq588= >$ *2555###>>rcZd} |j}|n|}|dz }t||j|fS)zP Return information about the innermost exception context in the chain. rTNr) __context__typeargs)excdepthcontexts rget_innermost_contextr(0sG E/ ?     IIsx ''rceZdZdZdZdS)DummycdS)Nzrselfs r__repr__zDummy.__repr__BsyrcdSr r)r-r$s r__call__zDummy.__call__E rN)__name__ __module__ __qualname__r.r0rrrr*r*@s2     rr*c&eZdZdZdZdZdZdS)CoroLikeObjectc tdN*) StopIteration)r-vs rsendzCoroLikeObject.sendJsBrcdSr r)r-r%s rthrowzCoroLikeObject.throwMr1rcdSr rr,s rclosezCoroLikeObject.closePr1rc|Sr rr,s r __await__zCoroLikeObject.__await__Ss rN)r2r3r4r<r>r@rBrrrr6r6IsP         rr6ceZdZdZdZdrdZdZfdZdZdZ dZ d Z d Z d Z d Zd ZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZdZ dZ!d Z"d!Z#d"Z$d#Z%d$Z&d%Z'd&Z(d'Z)d(Z*d)Z+d*Z,d+Z-d,Z.d-Z/d.Z0d/Z1d0Z2d1Z3d2Z4d3Z5d4Z6d5Z7d6Z8d7Z9d8Z:d9Z;d:Zd=Z?d>Z@d?ZAd@ZBdAZCdBZDdCZEdDZFdEZGdFZHdGZIdHZJdIZKdJZLdKZMdLZNdMZOdNZPdOZQdPZRdQZSdRZTdSZUdTZVdUZWdVZXdWZYdXZZdYZ[dZZ\d[Z]d\Z^d]Z_d^Z`eajbd_d`ZcdaZddbZedcZfddZgeajbd_deZhdfZidgZjdhZkdiZldjZmdkZndlZodmZpdnZqdoZrdpZsdqZtxZuS)s BaseTaskTestsNTestTaskc>|j||||S)N)loopnamer') __class__Task)r-rGcororHr's rnew_taskzBaseTaskTests.new_task\s!~""4dw"OOOrc8|j|SNrG)rIFuturer-rGs r new_futurezBaseTaskTests.new_future_s~$$$$///rct_jjfdj_dS)Nc8jSr )rRrGr,srz%BaseTaskTests.setUp..fs$//$)*D*Dr)supersetUp new_test_looprGset_task_factoryrL create_futurer-rIs`rrWzBaseTaskTests.setUpbsY  &&((  ""4=111"D"D"D"D rc|jjt}||jtf||t dSr )rIrJstr assertEqual__args__assertIsInstancerr-tasks rtest_generic_aliasz BaseTaskTests.test_generic_aliashsG~"3' /// dL11111rcd}||j|}|t|d||jd|d||jd|tj 5}|j |dddn #1swxYwY|d|j j ddS)Nc KdSr rrrrrKz;BaseTaskTests.test_task_cancel_message_getter..coron Dr_cancel_message my messager) rLrG assertTruehasattrr^rgcancel assertRaisesr CancelledErrorrun_until_complete exceptionr$r-rKtcms rtest_task_cancel_message_getterz-BaseTaskTests.test_task_cancel_message_getterms4    MM$)TTVV , , #455666 *D111  *L999   w5 6 6 ," I ( ( + + + , , , , , , , , , , , , , , , r|'8';<<<<.coro}rfrrhzmy new messager) rLrGrkrgr^rlr rmrnror$rps rtest_task_cancel_message_setterz-BaseTaskTests.test_task_cancel_message_setter|s    MM$)TTVV , , , *,<===   w5 6 6 ," I ( ( + + + , , , , , , , , , , , , , , , )2<+.Evilc,tjdSr )gccollectr,s r__del__z9BaseTaskTests.test_task_del_collect..Evil.__del__s rN)r2r3r4r}rrrEvilrys#     rr~cKSr r)r~srrunz0BaseTaskTests.test_task_del_collect..runs466MrcVg|]%}j&Sr)rLrG).0_rr-s r z7BaseTaskTests.test_task_del_collect..s<45 di//rd)rGrnr gatherrange)r-r~rs`@@rtest_task_del_collectz#BaseTaskTests.test_task_del_collects              $$ N9>s      rcdtj}||}d} |td5|j||dddn #1swxYwY|dS#|wxYw)NcK|d{VdSr rfuts rrz1BaseTaskTests.test_other_loop_future..runsIIIIIIIIIrzTask .* got Future .* attached)r new_event_looprRassertRaisesRegex RuntimeErrorrGrnr@)r- other_looprrs rtest_other_loop_futurez$BaseTaskTests.test_other_loop_futures+-- ooj))    '' (IKK 7 7 ,,SSXX666 7 7 7 7 7 7 7 7 7 7 7 7 7 7 7        J      s/B$A8, B8A<<B?A<BB/cfd}tj||j|td5|jddddS#1swxYwYdS)NcKd{VdSr r)rbsrtestz6BaseTaskTests.test_task_awaits_on_itself..testsJJJJJJJJJrrOzTask cannot await on itself)r ensure_futurerGrrrn)r-rrbs @rtest_task_awaits_on_itselfz(BaseTaskTests.test_task_awaits_on_itselfs     $TTVV$)<<<  # #L$ACC / / I ( ( . . . / / / / / / / / / / / / / / / / / /sA--A14A1cd}||j|}|j|||||d||j|j|| |jtj }| ||||}||j|||| dS)Nc KdSNokrrrrnotmuchz.BaseTaskTests.test_task_class..notmuch 4rr)rLrGrnridoner^resultassertIs_loopget_loopr rset_event_loopr@)r-rrqrGs rtest_task_classzBaseTaskTests.test_task_classs&    MM$)WWYY / / $$Q''' !!! T*** agty))) ajjllDI...%'' D!!! MM$ * * agt$$$ """ rcXdtj|j}||j|j|j||||| d}| |j | td5tj|dddn #1swxYwYfd}|j|}||j|j|j||||| dtj|j| tjdtj}||j|j|j||||| ddS)Nc KdSrrrrrrz;BaseTaskTests.test_ensure_future_coroutine..notmuchrrrOrno current event loopc@KtjSr r r)rsrrz8BaseTaskTests.test_ensure_future_coroutine..tests(33 3r)r rrGrrrnrirr^r addCleanupr@rrr)r-rqarrs @rtest_ensure_future_coroutinez*BaseTaskTests.test_ensure_future_coroutinesy     !''))$) < < < agty))) $$Q''' !!! T*** GII     # #L2I J J % %  !! $ $ $ % % % % % % % % % % % % % % % 4 4 4 4 4 I ( ( 0 0 agty))) $$Q''' !!! T*** ty))) .555  !'')) , , agty))) $$Q''' !!! T*****s0DDDc||j}|dtj|}|j||||| d| ||tj }| || t5tj||}dddn #1swxYwY|tj||j}| ||dS)NkorO)rRrG set_resultr rrnrirr^rrrrrl ValueErrorr@)r-f_origfrGs rtest_ensure_future_futurez'BaseTaskTests.test_ensure_future_futures{++$  !& ) ) $$Q''' !!! T*** a   %'' D!!!   z * * 9 9%f4888A 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9  !&ty 9 9 9 a     sD((D,/D,cd}||j|}tj|}|j|||||d| ||tj }| || t5tj||}dddn #1swxYwY|tj||j}| ||dS)Nc KdSrrrrrrz6BaseTaskTests.test_ensure_future_task..notmuchrrrrO)rLrGr rrnrirr^rrrrrlrr@)r-rt_origrqrGs rtest_ensure_future_taskz%BaseTaskTests.test_ensure_future_tasks~   ty''))44  !& ) ) $$Q''' !!! T*** a   %'' D!!!   z * * 9 9%f4888A 9 9 9 9 9 9 9 9 9 9 9 9 9 9 9  !&ty 9 9 9 a     s<DD#&D#c>Gdd}d}tj}||tj|||}||||ddS)NceZdZdZdZdS)6BaseTaskTests.test_ensure_future_awaitable..Awc||_dSr rKr-rKs r__init__z?BaseTaskTests.test_ensure_future_awaitable..Aw.__init__ s   rc4|jSr )rKrBr,s rrBz@BaseTaskTests.test_ensure_future_awaitable..Aw.__await__ sy**,,,rN)r2r3r4rrBrrrAwr s2 ! ! ! - - - - -rrc KdSrrrrrrKz8BaseTaskTests.test_ensure_future_awaitable..cororrrOr)r rrrrnr^r)r-rrKrGrs rtest_ensure_future_awaitablez*BaseTaskTests.test_ensure_future_awaitable s - - - - - - - -    %'' D!!!#BBttvvJJT::: $$$ t,,,,,rc|t5tjdddddS#1swxYwYdSr)rl TypeErrorr rr,s rtest_ensure_future_neitherz(BaseTaskTests.test_ensure_future_neithers   y ) ) ( (  !$ ' ' ' ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( ( (s=AActj}||j}|t d5tj||dddn #1swxYwY|dS)NzRThe future belongs to a different loop than the one specified as the loop argumentrO)r rrRrGrrrr@)r-rGrs rtest_ensure_future_error_msgz*BaseTaskTests.test_ensure_future_error_msgs%'' OODI & &  # #J1899 0 0  !!$ / / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 s A,,A03A0czdfdfdfd}j|dS)Nc,Kd{VdSr r)barsrfooz)BaseTaskTests.test_get_stack..foo)s"#%%KKKKKKKKKrclKd} |djjdd}n#d}wxYwt j}d||d|} |ddS)Nr)limitrr)rfilezfoo\(\) running) get_stackr^f_codeco_nameioStringIO print_stackseekread assertRegex)rrtbTr-s rrz)BaseTaskTests.test_get_stack..bar,s ! $$A   1!4e<<<D;==D MMM - - - IIaLLLB   R!3 4 4 4 4 4s &AAcbKtjjd{VdSrN)r rrG)rrr-srrunnerz,BaseTaskTests.test_get_stack..runner;s9%ccee$)<<.notmuchE 5rrz#\w+.test_task_repr..notmuchrz-BaseTaskTests.test_task_repr..notmuchrunningT)rz0()]>z3()]>rz#z/)rG set_debugr^r2rr4r3 test_utilsget_function_sourcerLadd_done_callbackr*r _source_tracebackreprrkrlr rmrn) r-rfilenamelinenorgen coro_qualnamerqrKs rtest_task_reprzBaseTaskTests.test_task_reprBs E"""    )9555 -? A A A +X666%9'BB&!66*giiG  y111 )=999 MM$)S ) ) EGG$$$ y# ! 3tEEE aKdR T T T   aNQUU W W W '0)6 ; ; ; vs ! 355 a>E G G G MM$)WWYY / / $$Q''' vs ! 355 aJTQ S S S S Srcd}||j|d}||j|d}|t|t|t jdt|}||t jdt|}|||t| dt| d|j ||j |dS)Nc KdSN{rrrrrz;BaseTaskTests.test_task_repr_autogenerated..notmuchv 3rz ^.notmuchrrz{6})rLrGset_namer^get_namern)r-rrqs rtest_task_repr_name_not_strz)BaseTaskTests.test_task_repr_name_not_strsy    MM$)WWYY / / A3 u--- $$Q'''''rc |jdd}||j}||j||}t j|j|t|dtj t|z| d|j |dS)NFcK|d{VSr rrs rwait_forz7BaseTaskTests.test_task_repr_wait_for..wait_fors999999 rz) rGrrRrLr run_brieflyrrrescaperrn)r-rrrbs rtest_task_repr_wait_forz%BaseTaskTests.test_task_repr_wait_fors E"""   oodi((}}TY 66ty))) d029T#YY3G3GG I I I t $$T*****rcfd}dd|}||j|ddS)NcRKd{V}d{V}||zSr r)rbinner1inner2s routerz-BaseTaskTests.test_task_basics..outers>fhhAfhhAQ3Jrc KdSr8rrrrrz.BaseTaskTests.test_task_basics..inner1 2rc KdS)Nirrrrrz.BaseTaskTests.test_task_basics..inner2rri)r^rGrn)r-rrqrrs @@rtest_task_basicszBaseTaskTests.test_task_basicssy              EGG 55a88$?????rc2tjdfd} |}|dS#wxYw)NcKtr rrrr raise_errorzFBaseTaskTests.test_exception_chaining_after_await..raise_errors  rcK td#t$r}} |d{Vnw#t$rj}t |t |j}t ||jftdfYd}~nd}~wwxYwYd}~dSYd}~dSd}~wwxYw)N)r)KeyError ExceptionrLr^r#rr"r$)r%rbchainedrGrr-s rrz>BaseTaskTests.test_exception_chaining_after_await..runs *qkk! * * *}}T;;==99*JJJJJJJJ ***$$T#YY ;;;!oG$$d7mmW\%B!4(*********JJJJJ****** *s> CC AC  B:A B50C 5B::C  C)r rrrLrnr@)r-rrbrGrs` @@r#test_exception_chaining_after_awaitz1BaseTaskTests.test_exception_chaining_after_awaits%'' D!!!    * * * * * * * ==ssuu--D  # #D ) ) ) JJLLLLLDJJLLLLs 3BBchdtjdfd} |}|n#wxYwddS)Nc K|r r)r%s r process_exczYBaseTaskTests.test_exception_chaining_after_await_with_context_cycle..process_excs IrcK td#t$ra}|} |d{Vn'#t$r}||jud|_Yd}~nd}~wwxYwYd}~dSYd}~dSd}~wwxYw)Nr)rrrL BaseExceptionr")r%rb has_cyclerGr!r-s rrzQBaseTaskTests.test_exception_chaining_after_await_with_context_cycle..runs +smm# + + +}}T;;s+;+;<<+JJJJJJJJ$+++!$!7I&*COOOOOO+JJJJJ$OOOOO +s= A?A:AA: A+A&!A:&A++A::A?F)r rrrLrnr@r^)r-rrbr$rGr!s` @@@r6test_exception_chaining_after_await_with_context_cyclezDBaseTaskTests.test_exception_chaining_after_await_with_context_cycles %'' D!!!    + + + + + + + + ==ssuu--D  # #D ) ) ) JJLLLLDJJLLLL E*****s 3BBc&tj}d} |||}|||dt |||||| dt |||| tj 5| |dddn #1swxYwY| dS#| wxYw)Nc>Ktjdd{VdSN r sleeprrrrbz+BaseTaskTests.test_cancelling..task.-## # # # # # # # # #r cancelling )r rrL assertFalse cancelling assertNotInrrirkassertInrlrmrnr@r-rGrbrqs rtest_cancellingzBaseTaskTests.test_cancellings%'' $ $ $  dDDFF++A   Q\\^^ , , ,   ^T!WW 5 5 5 OOAHHJJ ' ' ' OOALLNN + + + MM.$q'' 2 2 2 OOAHHJJ ' ' '""7#9:: + +''*** + + + + + + + + + + + + + + + JJLLLLLDJJLLLLs0DE:7E E:EE: E!E::Fc`tj}d} |||}|tjd|||dt|| | d| | |tjd| dt|| | d| | ||| | d| | |tj5||dddn #1swxYwY|| ||||| |||dS#|wxYw)NcK tjdd{VdS#tj$rCtjtjdd{VYdSwxYwr()r r+rm current_taskuncancelrrrrbz/BaseTaskTests.test_uncancel_basic..tasks (mB''''''''''') ( ( ($&&//111mB'''''''''''' (s AA21A2{Gz?r-rr)r rrLrnr+rirkr1rr^r/r. cancelledr0rlrmrr7r@r2s rtest_uncancel_basicz!BaseTaskTests.test_uncancel_basics%'' ( ( (  dDDFF++A  # #GM$$7$7 8 8 8 OOAHHJJ ' ' ' MM.$q'' 2 2 2   Q\\^^Q / / /   Q[[]] + + +  # #GM$$7$7 8 8 8   ^T!WW 5 5 5   Q\\^^Q / / /   Q[[]] + + + OOAHHJJ ' ' '   Q\\^^Q / / /   Q[[]] + + +""7#9:: + +''*** + + + + + + + + + + + + + + + OOAKKMM * * * OOAFFHH % % % JJLLL OOAKKMM * * * OOAFFHH % % % JJLLLLLDJJLLLLs1H L$I: LI  L I B3LL-c6tj}dtdtffd } ||dd}||\}}}||||d||dd}||\}}}||||d| dS#| wxYw)Nr+timeoutcKtj}dd}d}fd}|||} tj|d{Vd}|rDdkr,tjdtj urtn_#|rDdkr,tjdtj urtwxYwn%#t$r YnwxYwd}tjdd{V||fS)NFc4ddSNTrk)rb timed_outsr on_timeoutzdBaseTaskTests.test_uncancel_structured_blocks..make_request_with_timeout..on_timeoutFs  rTr) r r6r call_laterr+rkr7sysexc_inform TimeoutErrorri) r+r<rGstructured_block_finishedouter_code_reachedrBtimeout_handlerbrAr-s @@rmake_request_with_timeoutzPBaseTaskTests.test_uncancel_structured_blocks..make_request_with_timeout>s'))D==??DI(- %!&        "__WjAAN+ +(+!-.........04-"))+++!"+ MMOOq00LNN1-1GGG>+*G#))+++!"+ MMOOq00LNN1-1GGG>+***** + + + ***** +"& -"" " " " " " " "79KK Ks&C-AD(AD$$D((E  E $@皙?)r+r<r) r rfloatrLrnrir.r^r/r@)r-rGrJrrArGrHrs` rtest_uncancel_structured_blocksz-BaseTaskTests.test_uncancel_structured_blocks.s%''> Le> Le> L> L> L> L> L> L@ t%>%>TSV%W%W%WXXB''++ EI02D OOI & & &   6 7 7 7 OO. / / /   R]]__a 0 0 0t%>%>QPT%U%U%UVVB''++ EI02D   Y ' ' ' OO5 6 6 6 OO. / / /   R]]__a 0 0 0 JJLLLLLDJJLLLLs EFFc4fd}|}d}||}||jt j5||dddn #1swxYwY| |  |dS)Nc3HKdV}d|dVdSNrKrassertAlmostEqualwhenr-s rrz&BaseTaskTests.test_cancel..gen355D  " "4 . . .GGGGGrc>Ktjdd{VdS)NrK r*rrrrbz'BaseTaskTests.test_cancel..tasks--%% % % % % % % %2r) rXrL call_soonrkrlr rmrnrirr9r.)r-rrGrbrqs` r test_cancelzBaseTaskTests.test_cancelsE      !!#&&    MM$ ' ' qx     w5 6 6 ' '  # #A & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' !!!  &&& $$$$$s6BBBch gd}|D]%\}5tj  d  fd} |}tj5} |dddn #1swxYwY|j} |j |t|} |tj|dfdddn #1swxYwY'dS)N)rr)r r)rhr])r^ cancel_argsc>Ktjdd{VdSr(r*rrrr+zHBaseTaskTests.test_cancel_with_message_then_future_result..sleep.!-+++++++++++rcK}tjdd{V|jtj|gd{V\}}|dSNr)rLr r+rkwaitrrbrpendingrarGr-r+s rrKzGBaseTaskTests.test_cancel_with_message_then_future_result..coros==uuww77D!-*********DK--*1,v*>*>$>$>$>$>$>$>MD'KKMMMMMrr subTestr rrrLrlrmrnror^r$r( r-cases expected_argsrKrbrrr%actualrarGr+s ` @@@r+test_cancel_with_message_then_future_resultz9BaseTaskTests.test_cancel_with_message_then_future_results   +0 @ @ &K+66 @ @-//##D))),,,""""""""}}T446622&&w'=>>2"++D111222222222222222l  =999.s33  +]A>@@@+ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @7A1D%B:. D%:B> >D%B> AD%%D) ,D) ch gd}|D]%\}5tj  d  fd} |}tj5} |dddn #1swxYwY|j} |j |t|} |tj|dfdddn #1swxYwY'dS)Nr\r`c>Ktjdd{VdSr(r*rrrr+zKBaseTaskTests.test_cancel_with_message_then_future_exception..sleeprcrcK}tjdd{V|jtj|gd{V\}}|dSrerLr r+rkrfrorgs rrKzJBaseTaskTests.test_cancel_with_message_then_future_exception..coros==uuww77D!-*********DK--*1,v*>*>$>$>$>$>$>$>MD'NN$$$$$rrrirks ` @@@r.test_cancel_with_message_then_future_exceptionz>2"++D111222222222222222l  =999.s33  +]A>@@@+ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @ @rpctjfdfd}|}t 5}|dddn #1swxYwY|j} |j dt|} |tj ddfdS)NcjKdtjdd{VdSr()rr r+rsrr+z@BaseTaskTests.test_cancellation_exception_context..sleepsA NN4 -## # # # # # # # # #rcK}d{V|jd |d{VdS#tj$r}t d|d}~wwxYw)Nmsgr9)rLrYrkr rmr) inner_taskexrrGr-r+s rrKz?BaseTaskTests.test_cancellation_exception_context..corostUUWW55JIIIIIII NN:,e 4 4 4 6          ) 6 6 6 --25 6sAA4A//A4)r9)ryr) r rrrZrLrlrrnror^r$r(rm) r-rKrbrrr%rnrrGr+s ` @@@r#test_cancellation_exception_contextz1BaseTaskTests.test_cancellation_exception_contextsl%'' D!!!  "" $ $ $ $ $ 6 6 6 6 6 6 6 6}}T4466**   z * * *b  # #D ) ) ) * * * * * * * * * * * * * * *l >222&s++   #Xq 1 3 3 3 3 3sB((B,/B,ctjdfd}|}tj5}|dddn #1swxYwY|j}|j dt|}|tjddfdS)Nc>Ktjdd{VdSr(r*rrrr+zJBaseTaskTests.test_cancel_with_message_before_starting_task..sleepr,rcK}|dtj|gd{V\}}|dS)Nrh)rLrkr rfro)rbrrhrGr-r+s rrKzIBaseTaskTests.test_cancel_with_message_before_starting_task..coroso==uuww//D KK % % %"),v"6"6666666MD' NN     rr]r) r rrrLrlrmrnror^r$r()r-rKrbrrr%rnrGr+s` @@r-test_cancel_with_message_before_starting_taskz;BaseTaskTests.test_cancel_with_message_before_starting_task sN%'' D!!! $ $ $       }}T4466**   w5 6 6 *"  # #D ) ) ) * * * * * * * * * * * * * * *l ?333&s++   #_a 8 : : : : :s3BBBcd}||j|}tj|j||t j|jj|| | | | | |dS)NcrKtjdd{Vtjdd{VdS)NrrXr*rrrrbz-BaseTaskTests.test_cancel_yield..task%sO-"" " " " " " " "-"" " " " " " " "2r) rLrGrrrkrlr rmrnrirr9r.)r-rbrqs rtest_cancel_yieldzBaseTaskTests.test_cancel_yield$s    MM$)TTVV , ,ty)))     "DI$@! E E E !!!  &&& $$$$$rc$||jfd}||j|}tj|j|tj5|j |dddn #1swxYwY|  | | dS)NcKd{VdSNrXrrsrrbz4BaseTaskTests.test_cancel_inner_future..task6GGGGGGG2r) rRrGrLrrrkrlr rmrnrir9r-rbrqrs @rtest_cancel_inner_futurez&BaseTaskTests.test_cancel_inner_future3s( OODI & &      MM$)TTVV , ,ty)))    w5 6 6 , , I ( ( + + + , , , , , , , , , , , , , , ,  &&&  &&&&&sB77B;>B;c||jfd}||j|}tj|j||tj5|j |dddn #1swxYwY| | |  | | dS)NcKd{VdSrrrsrrbzBBaseTaskTests.test_cancel_both_task_and_inner_future..taskErr) rRrGrLrrrkrlr rmrnrirr9rs @r&test_cancel_both_task_and_inner_futurez4BaseTaskTests.test_cancel_both_task_and_inner_futureBsQ OODI & &      MM$)TTVV , ,ty)))      w5 6 6 , , I ( ( + + + , , , , , , , , , , , , , , , !!!  &&&  &&&&&s$C  CCc||j||jfd}||j|}tj|j||jdtj|j||j||  |j |}| |d| | dS)NcZKd{V d{VdS#tj$rYdSwxYwr8r rm)fut1fut2srrbz5BaseTaskTests.test_cancel_task_catching..taskZsWJJJJJJJ  )   rr s **r9rRrGrLrrr _fut_waiterrrkrir9rnr^r.)r-rbrqresrrs @@rtest_cancel_task_catchingz'BaseTaskTests.test_cancel_task_catchingVs?ty))ty))       MM$)TTVV , ,ty))) amT*** ty))) amT***   (()))i**1-- b!!! '''''rc||j||j||jfd}||j|}tj|j||jdtj|j||j||  tj|j||jd|j |}| |d|  | | dS)NcjKd{V d{Vn#tj$rYnwxYwd{V}|Sr r)rrrfut3s rrbz5BaseTaskTests.test_cancel_task_ignoring..taskrsiJJJJJJJ  )    ******CJs ((r9r)r-rbrqrrrrs @@@rtest_cancel_task_ignoringz'BaseTaskTests.test_cancel_task_ignoringmsty))ty))ty))        MM$)TTVV , ,ty))) amT*** ty))) amT***   (()))ty))) amT*** i**1-- b!!! ))*** '''''rcZtj}|fd}||tj|j   j  dS)NcKjtjdd{VdS)NrrX)rkri _must_cancelr r+r-rqsrrbz4BaseTaskTests.test_cancel_current_task..tasksO HHJJJ OOAN + + +-$$ $ $ $ $ $ $ $2r r rrrLr.r9rlrmrnrirrrkr2s` @rtest_cancel_current_taskz&BaseTaskTests.test_cancel_current_tasks%'' D!!!       MM$ ' ' '''   "D$;Q @ @ @ !!!  &&& ((( $$$$$rcZtj}|fd}||tj|j   j  dS)z+coroutine end right after task is cancelledchKjdSr)rkrirrsrrbz.BaseTaskTests.test_cancel_at_end..tasks- HHJJJ OOAN + + +2rNrr2s` @rtest_cancel_at_endz BaseTaskTests.test_cancel_at_ends%'' D!!!       MM$ ' ' '''   "D$;Q @ @ @ !!!  &&& ((( $$$$$rcttjfddxfdfd}|tj5dddn #1swxYwY   dS)Nc,Sr )r@rOsrrUz8BaseTaskTests.test_cancel_awaited_task..s rcKd{VdSr rrsrnestedz6BaseTaskTests.test_cancel_awaited_task..nestedIIIIIIIIIrcKtjdd{Vd{VdSrerLr r+rk)rGr nested_taskr-rbsrrKz4BaseTaskTests.test_cancel_awaited_task..coross--ffhh77K-"" " " " " " " " KKMMM         r) r rrrRrLrlrmrnrir9)r-rKrrGrrrbs` @@@@@rtest_cancel_awaited_taskz&BaseTaskTests.test_cancel_awaited_tasks%'' ,,,,---!!{ood##              }}T4466**   w5 6 6 * *  # #D ) ) ) * * * * * * * * * * * * * * * (()))  --//000  (((((sB88B<?B<c:||vrtd|d|ddS)Nztext z not found in: >>>z<<<r)r-textsubstrs rassert_text_containsz"BaseTaskTests.assert_text_containss7   MvMMDMMMNN N  rctjdfd}|} |ddS#tj$rCtj} |d |dYdSwxYw)Nc>Ktjdd{VdSr(r*rrrrzEBaseTaskTests.test_cancel_traceback_for_future_result..nested.-## # # # # # # # # #rcK}tjdd{V||d{VdSrer)rbrGrr-s rrKzCBaseTaskTests.test_cancel_traceback_for_future_result..corosd==vvxx00D-"" " " " " " " " KKMMMJJJJJJJJJrCancelledError did not occurawait asyncio.sleep(10)zawait task # search target r rrrLrnfailrm traceback format_excrr-rKrbrrGrs` @@r'test_cancel_traceback_for_future_resultz5BaseTaskTests.test_cancel_traceback_for_future_results%'' D!!! $ $ $        }}T4466** 6  # #D ) ) ) II4 5 5 5 5 5 % I I I%''B  % %b*C D D D  % %b*G H H H H H H  IBACCctjdfd}|} |ddS#tj$rCtj} |d |dYdSwxYw)Nc>Ktjdd{VdSr(r*rrrrzHBaseTaskTests.test_cancel_traceback_for_future_exception..nestedrrcK}tjdd{V|tj|gd{V\}}|dSrert)rbrrhrGrr-s rrKzFBaseTaskTests.test_cancel_traceback_for_future_exception..coros==vvxx00D-"" " " " " " " " KKMMM"),v"6"6666666MD' NN     rrrz!task.exception() # search targetrrs` @@r*test_cancel_traceback_for_future_exceptionz8BaseTaskTests.test_cancel_traceback_for_future_exceptions%'' D!!! $ $ $       }}T4466** 6  # #D ) ) ) II4 5 5 5 5 5% 5 5 5%''B  % %b*C D D D  % %b3 5 5 5 5 5 5  5rcfd}|dfd}|}t5}|dddn #1swxYwYt |jd| d d | tjj|dS)Nc3KdV}d|dV}d|dV}d|dVdS)NrL皙?333333?rRrTs rrz:BaseTaskTests.test_stop_while_run_in_complete..gensq55D  " "3 - - -99D  " "3 - - -99D  " "3 - - -IIIIIrrcKdkrAtjdd{Vdz dkrdk?dSdS)Nr)rLr)r r+stop)rGxsrrbz;BaseTaskTests.test_stop_while_run_in_complete..task!sdb&&mC(((((((((Q66IIKKK b&&&&&&rz+Event loop stopped before Future completed.rr)rXrLrlrrnr^r]ror.rrStimerkr rm)r-rrbrqrrrGrs` @@rtest_stop_while_run_in_completez-BaseTaskTests.test_stop_while_run_in_completes     !!#&&        MM$ ' '   | , , '  # #A & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' R\**F H H H """ A sDIIKK000   '0$2I1MMMMMsBBBcd}||j|}|td5d|_dddn #1swxYwY|j|dS)Nc KdSr rrrrrKz.BaseTaskTests.test_log_traceback..coro6rfrzcan only be set to FalseT)rLrGrr_log_tracebackrnr-rKrbs rtest_log_tracebackz BaseTaskTests.test_log_traceback5s   }}TY//  # #J0J K K ' '"&D  ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' $$T*****sAAAcfd}|}|tjd|tjdfd}|||}|dd||||}d||ddS)Nc3|KdV}d|dV}d|dVdSNrLr333333?rRrTs rrz$BaseTaskTests.test_wait..gen@R55D  " "3 - - -77D  " "4 . . .JJJJJrrLrcKtjgd{V\}}|tg|tdSr8r rfr^setrrhrr r-s rrz$BaseTaskTests.test_wait..fooLso"),1v"6"6666666MD'   T31v;; / / /   Wcee , , ,2rr9rXrLr r+rnr^rSrr-rrGrrrr s` @@r test_waitzBaseTaskTests.test_wait>sP     !!#&& MM$ c 2 2 3 3 MM$ d 3 3 4 4        %%dmmD##%%&@&@AA b!!! tTYY[[111%%dmmD##%%&@&@AA tTYY[[111 b!!!!!rc d}|j|d}||jtj|||j|dg}|j|\}}|||td|DddhdS)Nc K|Sr rss rrKz:BaseTaskTests.test_wait_duplicate_coroutines..coro] Hrrspamc3>K|]}|VdSr rrrs r z?BaseTaskTests.test_wait_duplicate_coroutines..gs*66AQXXZZ666666r) rG create_taskrLr rfrnr.r^r)r-rKcrbrrhs rtest_wait_duplicate_coroutinesz,BaseTaskTests.test_wait_duplicate_coroutines[s    I ! !$$v,, / /}} I L!Q 5 5dd6ll C CD E EGG 44T:: g !!! 66666668HIIIIIrcX|t|jjt jt t jd}t j|gd}|t|jj||dS)NrKr return_when) rlrrGrnr rfrr+r@)r- sleep_coro wait_coros rtest_wait_errorszBaseTaskTests.test_wait_errorsis   4 L   ! ! ! ]4(( L*2>>>  *)6  C C C rcfd}|}|tjd}|tjd}|tj||gtj}||\}}|h||h||  |  |  d||d|tj||gdS)Nc3|KdV}d|dV}d|dVdS)NrKrrLrRrTs rrz4BaseTaskTests.test_wait_first_completed..genxsR55D  " "4 . . .77D  " "3 - - -IIIIIrrKrLrr))rXrLr r+rfFIRST_COMPLETEDrnr^r.rri assertIsNonerrSr advance_time)r-rrGrr rbrrhs` rtest_wait_first_completedz'BaseTaskTests.test_wait_first_completedvs     !!#&& MM$ d 3 3 4 4 MM$ c 2 2 3 3}}  L!QW-D E E EGG//55 g !d### !g&&& """ !!! !((**%%% sDIIKK000 "  aV 4 455555rcd}d}||j|}||j|}||jtj||gtj}|j|\}}|||h|||| | ||| | dS)Nc>Ktjdd{VdSrer*rrrcoro1z2BaseTaskTests.test_wait_really_done..coro1s.-"" " " " " " " " " "rcrKtjdd{Vtjdd{VdSrer*rrrcoro2z2BaseTaskTests.test_wait_really_done..coro2sP-"" " " " " " " "-"" " " " " " " " " "rr) rLrGr rfrrnr^rirrr)r-rrrr rbrrhs rtest_wait_really_donez#BaseTaskTests.test_wait_really_dones2 # # # # # # MM$)UUWW - - MM$)UUWW - -}} I L!QW-D E E EGG 44T:: g !Q&&& !!! !((**%%% !!! !((**%%%%%rcfd}|}|tjd}d}||}|tj||gtj}||\}}|h||h|d| | d|tj||gdS)Nc3HKdV}d|dVdSrQrRrTs rrz4BaseTaskTests.test_wait_first_exception..genrVrrKc$Ktd)Nerr)ZeroDivisionErrorrrrr%z4BaseTaskTests.test_wait_first_exception..excs#E** *rrrr) rXrLr r+rfFIRST_EXCEPTIONrnr^rSrr r-rrGrr%r rbrrhs ` rtest_wait_first_exceptionz'BaseTaskTests.test_wait_first_exceptionsP      !!#&& MM$ d 3 3 4 4 + + + MM$ & &}}  L!QW-D E E EGG//55 g !d### !g&&& q$))++... "  aV 4 455555rcjfd}|}|tjd}d}||}tj||gtj}||\}}|h||h|d| | d|tj||gdS)Nc3|KdV}d|dV}d|dVdS)NrKrr8rRrTs rrz.genR55D  " "4 . . .77D  " "4 . . .JJJJJrrKcXKtjdd{Vtd)Nr8rr r+rrrrr%z.excs6-%% % % % % % % %#E** *rrr8r)rrs ` r!test_wait_first_exception_in_waitz/BaseTaskTests.test_wait_first_exception_in_waits8     !!#&& MM$ d 3 3 4 4 + + + MM$ & &|QF0GHHH//55 g !d### !g&&& tTYY[[111 "  aV 4 455555rcDfd}|}|tjdd}||fd}|||d||||d|dS)Nc3|KdV}d|dV}d|dVdSrrRrTs rrz3BaseTaskTests.test_wait_with_exception..genrrrLcXKtjdd{Vtd)Nrreallyr rrrsleeperz7BaseTaskTests.test_wait_with_exception..sleepers6-%% % % % % % % %#H-- -rcLKtjgd{V\}}t|d|t t d|D}t|ddS)Nrc3BK|]}||VdSr )rors rrzFBaseTaskTests.test_wait_with_exception..foo..s/FFqAKKMM,E,E,E,E,EFFrr)r rfr^lenr)rrherrorsrr r-s rrz3BaseTaskTests.test_wait_with_exception..foos"),1v"6"6666666MD'   SYY * * *   Wcee , , ,FFDFFFFFF   S[[! , , , , ,rr)rXrLr r+rnrSr)r-rrGrrrr s` @@rtest_wait_with_exceptionz&BaseTaskTests.test_wait_with_exceptions1     !!#&& MM$ c 2 2 3 3 . . . MM$ * * - - - - - - -  dCCEE : :;;; tTYY[[111  dCCEE : :;;; tTYY[[11111rcfd}|}|tjd|tjdfd}|||d||d|tjgdS)Nc3KdV}d|dV}d|dV}d|dVdS)NrLrr)\(?rRrTs rrz1BaseTaskTests.test_wait_with_timeout..gensq55D  " "3 - - -77D  " "4 . . .77D  " "4 . . .JJJJJrrLrcKtjgdd{V\}}|tg|tgdS)Nrr<rrs rrz1BaseTaskTests.test_wait_with_timeout..foosw"),1vt"D"D"DDDDDDDMD'   T3s88 , , ,   Wc1#hh / / / / /rrr)) rXrLr r+rnrSrrrf)r-rrGrrr s` @@rtest_wait_with_timeoutz$BaseTaskTests.test_wait_with_timeouts     !!#&& MM$ c 2 2 3 3 MM$ d 3 3 4 4 0 0 0 0 0 0 0  dCCEE : :;;; tTYY[[111 "  aV 4 455555rcfd}|}|tjd}|tjd}|tj||gd\}}|t|g|t|gd| | d|tj||gdS)Nc3KdV}d|dV}d|dV}d|dVdSrrRrTs rrz8BaseTaskTests.test_wait_concurrent_complete..gen$sq55D  " "3 - - -77D  " "4 . . .77D  " "3 - - -IIIIIrrLrrr)) rXrLr r+rnrfr^rrSrr)r-rrGrr rrhs` rtest_wait_concurrent_completez+BaseTaskTests.test_wait_concurrent_complete"s4     !!#&& MM$ c 2 2 3 3 MM$ d 3 3 4 4// L!Q - - -// g sA3xx((( #qc((+++ sDIIKK000 "  aV 4 455555rcfd}|}|tjd|tjdfd}|||}|dd|dS)Nc3|KdV}d|dV}d|dVdSrrRrTs rrz;BaseTaskTests.test_wait_with_iterator_of_tasks..gen?rrrLrcKtjtgd{V\}}|t g|t dSr8)r rfiterr^rrs rrz;BaseTaskTests.test_wait_with_iterator_of_tasks..fooKsu"),tQF||"<"<<<<<<.genWs.GGGGGGJJJGGGGGrg?FcKtj|d{V|sdvrdvrdd|S)Nrr TgQ?)r r+addr)dtr completedrG time_shifteds rrz0BaseTaskTests.test_as_completed..sleepercsu-## # # # # # # # MM!    (C9$4$4 9I9I# !!$'''Hrr8rr rrczKg}tjgD]}||d{V|Sr r as_completedappend)valuesrrr rs rrz,BaseTaskTests.test_as_completed..foopsRF)1a)44 ' ' Agggggg&&&&Mrr) rXslow_callback_durationrrnrLrSrrir^) r-rrrrrr rr*rGr+s @@@@@@rtest_as_completedzBaseTaskTests.test_as_completedUs`    !!#&&&)#EE          GD#   GD#   GD#          %%dmmD##%%&@&@AA tTYY[[111 s2A2w''' s2A2w''' Q%%%%%rc4d}||tjddtjddfd}||}|t|d|||dd ||d dd||d d tj | d   d tj gdS) Nc3*KdVdVdVdVdS)NrrLrrrrrz9BaseTaskTests.test_as_completed_with_timeout..gen~s. EEEGGGGGGIIIIIrrLrrr cKg}tjgdD]l}|rd |d{V}|d|f:#tj$r!}|d|fYd}~ed}~wwxYw|S)NQ?rg{Gz?rr)r r.rr/rF)r0rr;r%rr rGs rrz9BaseTaskTests.test_as_completed_with_timeout..foosF)1a&$??? , ,,%%d+++,AMM1a&))))+,,,MM1c(++++++++,MsAB'BBrr)rrrr6r))rXrr r+rnrLr^rr`rFrSrrrf)r-rrrrr rGs @@@rtest_as_completed_with_timeoutz,BaseTaskTests.test_as_completed_with_timeout|s    !!#&&   W]344 5 5   W]455 6 6       %%dmmD##%%&@&@AA S1c*** Q*** QA&&& c!fQi)=>>> tTYY[[111 "  aV 4 455555rcd}|}tjddfd}|||dS)Nc3"KdVdVdVdSr&rrrrrz@BaseTaskTests.test_as_completed_with_unused_timeout..gens% EEEGGGJJJJJrr8rc|KtjgdD] }|d{V}|d!dS)Nrrr)r r.r^)rr;rr-s rrz@BaseTaskTests.test_as_completed_with_unused_timeout..foos\)1#q999 ) )GGGGGG  C(((( ) )r)rXr r+rnrL)r-rrGrrs` @r%test_as_completed_with_unused_timeoutz3BaseTaskTests.test_as_completed_with_unused_timeouts    !!#&& M$ $ $ ) ) ) ) ) )  dCCEE : :;;;;;rcd}|tjdd}tjdd}||hfd}|dS)Nc3"KdVdVdVdS)Nr皙?rrrrrz9BaseTaskTests.test_as_completed_reverse_wait..gens%GGGJJJGGGGGrr>rrLr cKttj}t |d|dd{V}|ddd|dd{V}|dddS)Nrrrr>rr rL)listr r.r^rrSrr)futsryfsrGr-s rrz:BaseTaskTests.test_as_completed_reverse_wait..tests,R0011D   SYY * * *1g A   Q $ $ $  " "4 5 5 5   d # # #1g A   Q $ $ $  " "4 5 5 5 5 5r)rXr r+rn)r-rrr rrCrGs` @@rtest_as_completed_reverse_waitz,BaseTaskTests.test_as_completed_reverse_waits    !!#&& M$ $ $ M$ $ $V 6 6 6 6 6 6 6 '''''rcfd}tjdd}tjdd}||hfd}|}||dS)Nc3|KdV}d|dV}d|dVdS)Nr>rrRrTs rrz7BaseTaskTests.test_as_completed_concurrent..genrrr>rr c@Kttj}t |dtjd|Dd{V\}}t d|DddhdS)Nrc6g|]}tj|Srr)rrs rrzLBaseTaskTests.test_as_completed_concurrent..test..s#<<<&s++<<K|]}|VdSr rrs rrzKBaseTaskTests.test_as_completed_concurrent..test..s* : : : : : : : :rrr )r@r r.r^rrfr)rArrhrCr-s rrz8BaseTaskTests.test_as_completed_concurrent..tests,R0011D   SYY * * *"),<.cororrcKg}d}tj||dgD]}||d{V|S)Nhamrr-)rrrrKs rrzDBaseTaskTests.test_as_completed_duplicate_coroutines..runnershFU A)1af*>?? ' ' Agggggg&&&&MrrNrr)rLrGrnrr^rr)r-rrrrKs @r&test_as_completed_duplicate_coroutinesz4BaseTaskTests.test_as_completed_duplicate_coroutiness        mmDIvvxx00 $$S))) Vufo666 Va(((((rcd}|}||jtj|g}|t d5t |ddddS#1swxYwYdS)Nc KdSr8rrrrrKzDBaseTaskTests.test_as_completed_coroutine_without_loop..cororrr)rr@r r.rrr@)r-rKrrAs r(test_as_completed_coroutine_without_loopz6BaseTaskTests.test_as_completed_coroutine_without_loops    DFF    #QC((  # #L2I J J   JJJ                  sA55A9<A9c~}dfd}||dS)Nc KdSr8rrrrrKzHBaseTaskTests.test_as_completed_coroutine_use_running_loop..cororrcKttjg}t |d|dd{VddS)Nrrr9)r@r r.r^r)rArKr-s rrzHBaseTaskTests.test_as_completed_coroutine_use_running_loop..testso,ddffX6677D   SYY * * *   47]]]]]]B / / / / /r)rXrn)r-rGrrKs` @r,test_as_completed_coroutine_use_running_loopz:BaseTaskTests.test_as_completed_coroutine_use_running_loopsd!!##    0 0 0 0 0 0 '''''rcfd}|}d}||dd}||||dd|dS)Nc3|KdV}d|dV}d|dVdS)Nr>rLrRrTs rrz%BaseTaskTests.test_sleep..gensR55D  " "4 . . .::D  " "3 - - -JJJJJrcKtj|dz d{Vtj|dz |d{V}|S)Nrr*)r)argrs rrz)BaseTaskTests.test_sleep..sleepersX-1%% % % % % % % % bdC00000000CJrrLyeah) rXrLrnrirr^rrSr)r-rrGrrqs` r test_sleepzBaseTaskTests.test_sleeps     !!#&&    MM$V 4 4 5 5 """ !!! V,,, sDIIKK00000rcfd}|}|tjdd}d|jfd}||_t j|j| t j| jdS)Nc3HKdV}d|dVdSrQrRrTs rrz,BaseTaskTests.test_sleep_cancel..gen'rVrrKr[c||g|RSr r)delaycallbackr$handleorig_call_laters rrCz3BaseTaskTests.test_sleep_cancel..call_later3s!$_UH.genCsR55D  " "3 - - -77D  " "4 . . .IIIIIrc>Ktj|d{VdSr r*)r)s rr+z;BaseTaskTests.test_task_cancel_sleeping_task..sleepLr,rcKd}d|j |d{VdS#tj$rYdSwxYw)NrhrLzslept inr9)rLrCrkr rm)rrGr-r+s rdoitz:BaseTaskTests.test_task_cancel_sleeping_task..doitOs|mmD%%++66G OOC 0 0 0 " "z) # # #"{{ #sA AAr9rL)rXr^rnrSr)r-rrkdoerrGr+s` @@rtest_task_cancel_sleeping_taskz,BaseTaskTests.test_task_cancel_sleeping_taskAs     !!#&& $ $ $ " " " " " " "tvv 0066 DDD sDIIKK00000rc&||jfd}||j|}tj|j||j|tj|j|tj |jj || |j| dS)NcKd{VdSr rrsrrKz:BaseTaskTests.test_task_cancel_waiter_future..coro`rr)rRrGrLrrrrrkrlr rmrnrrir9)r-rKrbrs @rtest_task_cancel_waiter_futurez,BaseTaskTests.test_task_cancel_waiter_future]soodi((     }}TY//ty))) d&,,, ty)))   "DI$@$ H H H $*+++  (((((rcd}|}||j|}|td5|ddddn #1swxYwY|td5|t dddn #1swxYwY||j|ddS)Nc KdS)Nrrrrrrz4BaseTaskTests.test_task_set_methods..notmuchorrznot support set_resultrznot support set_exceptionr) rLrGrrr set_exceptionrr^rn)r-rrrbs rtest_task_set_methodsz#BaseTaskTests.test_task_set_methodsnsq   gii}}TY,,  # #L2J K K " " OOD ! ! ! " " " " " " " " " " " " " " " # #L2M N N - -   z|| , , , - - - - - - - - - - - - - - -  I ( ( . .      s$A&&A*-A* "B::B>B>cXGddtj}||jdfd}||j|}t j|j|jt} |t j|j| ||| | | dS)Nc(eZdZfdZfdZxZS)2BaseTaskTests.test_step_result_future..FutcHd|_tj|i|dSNF)cb_addedrVr)r-r$kwdsrIs rrz;BaseTaskTests.test_step_result_future..Fut.__init__s, %   $/$/////rcHd|_tj|i|dSr?)rzrVrr-r$kwargsrIs rrzDBaseTaskTests.test_step_result_future..Fut.add_done_callbacks, $ ))4:6:::::rr2r3r4rr __classcell__rIs@rFutrwsQ 0 0 0 0 0 ; ; ; ; ; ; ; ; ;rrrOcKd{VdSr r)rrsrwait_for_futurez>BaseTaskTests.test_step_result_future..wait_for_futuresYYYYYYFFFr)r rPrGrLrrrirzobjectrrrrr)r-rrrqrrrs @@rtest_step_result_futurez%BaseTaskTests.test_step_result_futures- ; ; ; ; ;'. ; ; ;cty!!!       MM$)__%6%6 7 7ty)))  %%%hh sty))) c6""" !!! !((**%%%%%rcfd}|}dtfd}||}tj|||ttj| ||  | dS)Nc3HKdV}d|dVdSrQrRrTs rrz;BaseTaskTests.test_baseexception_during_cancel..genrVrc>Ktjdd{VdSr(r*rrrrz?BaseTaskTests.test_baseexception_during_cancel..sleeperr,rcXK d{VdS#tj$rwxYwr r)base_excrsrnotmutchz@BaseTaskTests.test_baseexception_during_cancel..notmutchsJ gii)    s)) rX SystemExitrLrrrkr.rrlrir9rro)r-rrGrrbrrs` @@r test_baseexception_during_cancelz.BaseTaskTests.test_baseexception_during_cancels7      !!#&& $ $ $<<       }}T88::..t$$$  %%% *j&.fns Drc3KdVdSr rrrrfn1z3BaseTaskTests.test_iscoroutinefunction..fn1s EEEEErc KdSr rrrrfn2z3BaseTaskTests.test_iscoroutinefunction..fn2rfr)r.r iscoroutinefunctionrirMock AsyncMock)r-rrrs rtest_iscoroutinefunctionz&BaseTaskTests.test_iscoroutinefunctions    4R88999    4S99:::    3C88999 4TY[[AABBB 3DN4D4DEEFFFFFrcd}|tj||}|tj||j|}||ddS)Nc KdSNrrrrrfuncz;BaseTaskTests.test_coroutine_non_gen_function..funcs 6rr)rir r iscoroutinerGrnr^)r-rrKrs rtest_coroutine_non_gen_functionz-BaseTaskTests.test_coroutine_non_gen_functions    3D99:::tvv +D11222i**400 f%%%%%rc||jfd}fd}||j|}||j|}|j|}||||dS)Nc KSr rrsrrzIBaseTaskTests.test_coroutine_non_gen_function_return_future..funcs Jrc6KddSrrrsrrKzIBaseTaskTests.test_coroutine_non_gen_function_return_future..coros NN6 " " " " "r)rRrGrLrnr^rr)r-rrKrrrrs @r-test_coroutine_non_gen_function_return_futurez;BaseTaskTests.test_coroutine_non_gen_function_return_futuresoodi((      # # # # #]]49ddff - - ]]49ddff - -i**2.. c""" "))++&&&&&rcPtjjfd}j|jjtjjdS)NrOcKtjtjdtjdSr )rr r6)rGr-rbs rrKz-BaseTaskTests.test_current_task..corosf MM'.00$ 7 7 7 MM'.t44d ; ; ; MM'.00$ 7 7 7 7 7r)rr r6rGrLrnrs` @rtest_current_taskzBaseTaskTests.test_current_tasks '.DI>>>??? 8 8 8 8 8 8 }}TYTY88 $$T*** '.DI>>>?????rcLtjjjjfd}fd}j|jj|jjtjftjjdS)NrOcKtjud{VtjuddSr?rir r6r)rGrrr-task1s rrzFBaseTaskTests.test_current_task_with_interleaving_tasks..coro1sp OOG022e; < < <JJJJJJJ OOG022e; < < < OOD ! ! ! ! !rcKtjudd{VtjudSr?r)rGrrr-task2s rrzFBaseTaskTests.test_current_task_with_interleaving_tasks..coro2sp OOG022e; < < < OOD ! ! !JJJJJJJ OOG022e; < < < < >>???ty))ty)) " " " " " " " "  = = = = = = = =  dity)9)9:: dity)9)9:: $$W\5%.%A%ABBB '.DI>>>?????rcdjfdfd}tj|j}t jj|j|d  dS)NrczK d{VddS#tj$rdz wxYw)Nzgot past sleep() in inner()r)rr rm)proofr-waitersrinnerz.innersd 9  788888 )     s$:cnK d{Vdz dS#tj$r dz YdSwxYw)Nr)rrrrsrrz.outer sa egg  )     s 44rOe) rRrGr rrrrkrnr^rir9r-rrrrrs` @@@rtest_yield_future_passes_cancelz-BaseTaskTests.test_yield_future_passes_cancels++ 9 9 9 9 9 9 9        !%%'' : : :ty)))   $$Q''' $$$ ((**+++++rcdjfdfd}tj|j}t jj|tjjj | dt jj ddS)Nrc&Kd{Vdz dSNrrrrsrrzCBaseTaskTests.test_yield_wait_does_not_shield_cancel..inner6%LLLLLLL QJEEErcKt5tjtjgd{V\}}dddn #1swxYwYdz dSNr) assertWarnsDeprecationWarningr rfr)dprrr-s rrzCBaseTaskTests.test_yield_wait_does_not_shield_cancel..outer;s!!"455 J J$\7+>uuww+G+G*HIIIIIIII1 J J J J J J J J J J J J J J J SLEEEs9A##A'*A'rOr rRrGr rrrrkrlrmrnrr^rs` @@@r&test_yield_wait_does_not_shield_cancelz4BaseTaskTests.test_yield_wait_does_not_shield_cancel0s ++                !%%'' : : :ty)))     "DI$@! E E E$ty))) """""rc||j}tj|}|d|j|}||ddSr8)rRrGr shieldrrnr^)r-rrrs rtest_shield_resultz BaseTaskTests.test_shield_resultJsi **u%% i**511 b!!!!!rc^||j}tj|}t j|jt d}||t j|j|| |dS)Nexpected) rRrGr rrrrrsrro)r-rrr%s rtest_shield_exceptionz#BaseTaskTests.test_shield_exceptionQs **u%%ty))):&& C   ty))) eoo''-----rc<||j}tj|}t j|j|t j|j||dSr ) rRrGr rrrrkrir9r-rrs rtest_shield_cancel_innerz&BaseTaskTests.test_shield_cancel_innerZsy **u%%ty))) ty))) ))*****rc||j}tj|}t j|j|t j|j||| d|j dnt|j dSre) rRrGr rrrrkrir9r^ _callbacksrrs rtest_shield_cancel_outerz&BaseTaskTests.test_shield_cancel_outerbs **u%%ty))) ty))) ))*** !1!9AAs5CS?T?TUUUUUrc||j}|d|jt j|}||ddSr8)rRrGrrnr rr^)r-rrs rtest_shield_shortcutz"BaseTaskTests.test_shield_shortcutksboodi(( ri**7>#+>+>?? b!!!!!rc&d||jfdfd}tj||j}t j|j||tj5|j |dddn #1swxYwY dt j|j| ddS)Nrc&Kd{Vdz dSrrrsrrz/BaseTaskTests.test_shield_effect..innervrrcZKtjd{Vdz dSrr rrsrrz/BaseTaskTests.test_shield_effect..outer{s<.)) ) ) ) ) ) ) ) SLEEErrOrrrs @@@rtest_shield_effectz BaseTaskTests.test_shield_effectqs]++               !%%'' : : :ty)))    w5 6 6 , , I ( ( + + + , , , , , , , , , , , , , , ,$ty))) """""sCC Cct||j}||j}tj||}tj|}t j|j|t j|j|| | d| dt j|j| | ddgdSNrr) rRrGr rrrrrkrir9rr^r)r-child1child2parentrs rtest_shield_gatherz BaseTaskTests.test_shield_gathers++++//v&&ty))) ty))) ))***!!ty))) 1a&11111rc||j}||j}tj|}tj|}tj||}t j|j|t j|j|| tj | | | | | d| dt j|jdSr)rRrGr rrrrrkr`rormrir9r)r-rrrrrs rtest_gather_shieldz BaseTaskTests.test_gather_shields,++++''''//ty))) ty))) f..00'2HIII ((**+++ ((**+++!!ty)))))rcd}|}||j|td5t j|ddddS#1swxYwYdS)Nc KdSr8rrrrrKz>BaseTaskTests.test_shield_coroutine_without_loop..cororrr)rr@rrr rr-rKrs r"test_shield_coroutine_without_loopz0BaseTaskTests.test_shield_coroutine_without_loops     $$$  # #L2I J J " " N5 ! ! ! " " " " " " " " " " " " " " " " " "sA%%A),A)cdfd}|j|}||j|j|j|}||ddS)Nc KdSr8rrrrrKzBBaseTaskTests.test_shield_coroutine_use_running_loop..cororrc@KtjSr rrsrrzBBaseTaskTests.test_shield_coroutine_use_running_loop..tests>$$&&)) )rr9)rGrnr^r)r-rrrrKs @r&test_shield_coroutine_use_running_loopz4BaseTaskTests.test_shield_coroutine_use_running_loops    * * * * * ,,TTVV44 di000i**511 b!!!!!rcVd}tj|j|tjdtj|}||j|j|j|}||ddS)Nc KdSr8rrrrrKzABaseTaskTests.test_shield_coroutine_use_global_loop..cororrr9)r rrGrrr^rrn)r-rKrrs r%test_shield_coroutine_use_global_loopz3BaseTaskTests.test_shield_coroutine_use_global_loops    ty))) .555ttvv&& di000i**511 b!!!!!rc^||j}|t|jjt j|t}|t|jjt j||dSr ) rRrGrlrrnr r.rr@r-rrKs rtest_as_completed_invalid_argsz,BaseTaskTests.test_as_completed_invalid_argssoodi(( )TY%A   % % ' ' '!## )TY%A   & & ( ( ( rc||j}|t|jjt j|t}|t|jjt j|||t|jjt jgdSr ) rRrGrlrrnr rfrr@rrs rtest_wait_invalid_argsz$BaseTaskTests.test_wait_invalid_argssoodi(( )TY%A L     !## )TY%A L       *di&B L       rcJjj}fd}tj}jdj||j}tj|j} tj j|htj dj  tjjdd}|j}d}t!j tj jt%|jdtj|d|dS)Nc`K|}|d{Vtd)Nzcode never reached)rRr)rGfuturer-s rkill_mez>BaseTaskTests.test_log_destroyed_pending_task..kill_mes:__T**FLLLLLLL011 1rTrOrz%Task was destroyed but it is pending!)messagerbr)rIrJrrrGrset_exception_handlerr rr^ all_tasksr _run_oncer_readyrr gc_collectrassert_called_withANY reset_mock)r-rJr mock_handlerrKrbrs` rtest_log_destroyed_pending_taskz-BaseTaskTests.test_log_destroyed_pending_tasks~" 2 2 2 2 2y{{  D!!! '' 555wty!!$T ::: * :::TFCCCt$$$  TY-..2221  * :::CEEBBB'' >H 04 4    !!!!!rzasyncio.base_events.loggerctjdfd}||jjdS)NcKtr )rrrrrKzBBaseTaskTests.test_tb_logger_not_called_after_cancel..coros OrcK}tjdd{V|d}dS)Nr>r)rbrKrGr-s rrzDBaseTaskTests.test_tb_logger_not_called_after_cancel..runnersX==ttvv..D-%% % % % % % % % KKMMMDDDr)r rrrnr.errorcalled)r-m_logrrKrGs` @@r&test_tb_logger_not_called_after_cancelz4BaseTaskTests.test_tb_logger_not_called_after_cancel s%'' D!!!           ))) +,,,,,rc|jd||jt}t jjdz }||jt| |jdddt|df|j |dS)NTrrtest_task_source_traceback) rGrrLrrD _getframef_linenor`rr@r^__file__rn)r-rbrs rr z(BaseTaskTests.test_task_source_tracebacks D!!!}}TY(:(<(<==)A- d4d;;; /3BQB7" 68 9 9 9 $$T*****rc.tj}||j||fd}||dfd}|d||d|  | dgdS)zYEnsure that a gathering future refuses to be cancelled once all children are donecrKfd}tj|}tj|S)Nc3KEd{VSr rrsr child_corozFBaseTaskTests.test_cancel_gather_1..create..child_coro3s#&'r)r rr)r gather_futurers rcreatez2BaseTaskTests.test_cancel_gather_1..create0sF ( ( ( ( (#N::<<88M(77 7rNc0dSr r@)r cancel_result gather_tasks rcancelling_callbackz?BaseTaskTests.test_cancel_gather_1..cancelling_callback:s'..00MMMrr9F) r rrr@rRrnrrr^r.r9r)r-rGrrrrrs @@@rtest_cancel_gather_1z"BaseTaskTests.test_cancel_gather_1)s2%''  ###ood## 8 8 8 8 8--ffhh77   1 1 1 1 1 1 1222 r  ,,, ... ..00111 ++--t44444rc 0gd}|D] \}5tjjdfd} |dni#tj$rW}|j |t|}|tj|dfYd}~nd}~wwxYwdddn #1swxYwY dS)Nr\r`cKd} |dz }tjtjddd{V|dkrdS<)NrTr>return_exceptionsr)r rr+)rs rrz0BaseTaskTests.test_cancel_gather_2..testVs|D# %nW]4-@-@?CEEEEEEEEEE!88"F #rcK}tjdd{V|j|d{VdS)Nrr)qwerarGr-rs rmainz0BaseTaskTests.test_cancel_gather_2..main_sf--ddff55C!-,,,,,,,,,CJ ,,IIIIIIIIIrzWgather() does not propagate CancelledError raised by inner task to the gather() caller.r) rjr rrr@rnrrmr^r$r() r-rlrmrr%rnrarGrs ` @@@rtest_cancel_gather_2z"BaseTaskTests.test_cancel_gather_2Is   +0! !  &K+66  -// +++### ++DDFF333IIG-$$SX}===2377F$$ /B+               ! ! s<9D !B>D C:#A C50D 5C::D  D D c`dfd}j|dS)NcKddz dS)Nrrrrrrrz3BaseTaskTests.test_exception_traceback..foows EEEErcKj}tjdd{V|jdSre)rLrGr r+rro __traceback__)rbrr-s rrz4BaseTaskTests.test_exception_traceback..mainzsk==CCEE22D-"" " " " " " " "  !1!1!? @ @ @ @ @rr)r-rrs` @rtest_exception_tracebackz&BaseTaskTests.test_exception_tracebackts[    A A A A A A $$TTVV,,,,,rcd}||j_d}||jj|t 5|} ||j||n#|wxYw dddn #1swxYwYtj | |jj|jj dd}| d||tj|jt#dS)Nctr r)rar$r~s rrYz8BaseTaskTests.test_error_in_call_soon..call_soons rc KdSr rrrrrKz3BaseTaskTests.test_error_in_call_soon..cororfrrz$Task was destroyed but it is pending)rGrYr.rrrlrrLr@r{r|ri call_argsr1r^r rr)r-rrYrKrrs rtest_error_in_call_soonz%BaseTaskTests.test_error_in_call_soonsq   '     +,,,   z * *  $&&C  di---                    *++++'*1- .cororfr)rLrGr`rJrnrs r$test_create_task_with_async_functionz2BaseTaskTests.test_create_task_with_async_functions   }}TY// dDI... $$T***}}TY// dDI... $$T*****rc||jt}|||j||j|d||jt}|||j||j|ddSr8)rLrGr6r`rJr^rnras r(test_create_task_with_asynclike_functionz6BaseTaskTests.test_create_task_with_asynclike_functions}}TY(8(899 dDI... 55d;;R@@@}}TY(8(899 dDI... 55d;;R@@@@@rc`dfd}j|dS)Nc KdSrrrrrrz2BaseTaskTests.test_bare_create_task..inners 1rcKtj}|j|d{V}d|dSr)r rr`rJr^)rbretrr-s rrKz1BaseTaskTests.test_bare_create_task..corosb&uuww//D  ! !$ 2 2 2******C   Q $ $ $ $ $rrrs` @rtest_bare_create_taskz#BaseTaskTests.test_bare_create_tasksU    % % % % % % $$TTVV,,,,,rc`dfd}j|dS)Nc KdSr rrrr coro_noopz.coro_nooprfrcKtjd}|d|d{VdS)NzNo-op)rH)r rr^r)rbr8r-s rrKz7BaseTaskTests.test_bare_create_named_task..corosU&yy{{AAAD   T]]__g 6 6 6JJJJJJJJJrr)r-rKr8s` @rtest_bare_create_named_taskz)BaseTaskTests.test_bare_create_named_tasksU          $$TTVV,,,,,rc>tjddfdfd}tj |}|dS#wxYw)NcvarnopedefaultcKtjdd{VdddS)Nr8r=something else)r r+r^getr)r<r-srsubz)BaseTaskTests.test_context_1..subs`-%% % % % % % % %   TXXZZ 0 0 0 HH% & & & & &rcrKd}dd|d{VddS)Nr=yes)r^rBrLr)subtaskr<rGr-rCs rrz*BaseTaskTests.test_context_1..mains   TXXZZ 0 0 0mmD##%%00G HHUOOO   TXXZZ / / /MMMMMMM   TXXZZ / / / / /r) contextvars ContextVarr rrLrnr@)r-rrbr<rGrCs` @@@rtest_context_1zBaseTaskTests.test_context_1s%ff=== ' ' ' ' ' '  0 0 0 0 0 0 0 0%'' ==ttvv..D  # #D ) ) ) JJLLLLLDJJLLLLs 3BBctjddfd}tj |}|n#wxYwddS)Nr<r=r>c Kfd}dtdD]}}||d||jd|d{Vd|tdD]e}d|d|tj dd{Vd|d|f dS)Nc2ddS)NrA)r)rr<s r fut_on_donez?BaseTaskTests.test_context_2..main..fut_on_dones)*****rr=rrEr-MbP?) r^rBrrRrrrYrr r+)rMjrir<rGr-s rrz*BaseTaskTests.test_context_2..mainsu + + + + +   TXXZZ 0 0 01XX @ @ood++%%k222q###s~t444   Y1YY777q@@AHH]1]]q]]+++!-.........$$TXXZZq1???? @ @ @r) rGrHr rrLrnr@r^rB)r-rrbr<rGs` @@rtest_context_2zBaseTaskTests.test_context_2s%ff=== @ @ @ @ @ @ @,%'' ==ttvv..D  # #D ) ) ) JJLLLLDJJLLLL V,,,,,s 3A==Bc`tjddfdfd}tj |n#wxYwddS)Nr<rr>cKtdD]r}||ztjt jddd{V||zsdS)Nr)rOr>)rrr r+randomuniformr^rB)numrQr<r-s rrCz)BaseTaskTests.test_context_3..sub s2YY 6 6q!!!mFN5$$?$?@@@@@@@@@  S1W5555 6 6rc Kg}tdD]C}tjdd}|j|Dt j|d{VdS)Nrrr))rrrUrandintr/r r)rrQrbrGrCs rrz*BaseTaskTests.test_context_3..main sE3ZZ # #''FN1b,A,A(B(BCC T"""".%( ( ( ( ( ( ( ( ( (r)rGrHr rrnr@r^rB)r-rr<rGrCs` @@@rtest_context_3zBaseTaskTests.test_context_3 s%fb999 6 6 6 6 6 6  ) ) ) ) ) )%''   # #DDFF + + + JJLLLLDJJLLLL R(((((s A--Bcjtjdfdfd}tj |}|}n#wxYwgd|dS)Nr<cjKtjdd{V|dSrer r+rvalr<s rrKz*BaseTaskTests.test_context_4..coro/ <-"" " " " " " " " HHSMMMMMrcKg}tj}||d|}|d{V||d|}|d{V|||SNr)r'r)rG copy_contextr/rBrL)r4ctxrrrKr<rGr-s rrz*BaseTaskTests.test_context_4..main3 sC*,,C JJswwt}} % % %tTT!WWc::BHHHHHHH JJswwt}} % % %tTT!WWc::BHHHHHHH JJswwt}} % % %JrrrGrHr rrLrnr@r^r-rrbr4rKr<rGs` @@@rtest_context_4zBaseTaskTests.test_context_4, s%f--             %'' ==ttvv..D))$//C JJLLLLDJJLLLL s+++++s 3BBcbtjdfdfd}tj} |||}||}|n#|wxYw|gd|dS)Nr<cjKtjdd{V|dSrer]r^s rrKz*BaseTaskTests.test_context_5..coroK r`rcKg}tj}||t jd|}|d{V||t jd|}|d{V|||Srb)rGrcr/rBr r)r4rdrrrKr<s rrz*BaseTaskTests.test_context_5..mainO sC*,,C JJswwt}} % % %$TT!WWc:::BHHHHHHH JJswwt}} % % %$TT!WWc:::BHHHHHHH JJswwt}} % % %Jrrre)r-rrGrbr4rKr<s @@rtest_context_5zBaseTaskTests.test_context_5H s%f--           %'' ==ttvv..D))$//C JJLLLLDJJLLLL s+++++s 3A>>Bcdtjdfdfd}tj |}|}n#wxYw|gd|dS)Nr<cjKtjdd{V|dSrer]r^s rrKz*BaseTaskTests.test_context_6..corog r`rcKg}tj}||d|}|d{V||d|}|d{V|||Srb)rGrcr/rBr)r4rdrrrKr<rGs rrz*BaseTaskTests.test_context_6..maink sC*,,C JJswwt}} % % %!!$$q''3!77BHHHHHHH JJswwt}} % % %!!$$q''3!77BHHHHHHH JJswwt}} % % %Jrr)rGrHr rrrnr@r^rfs @@@rtest_context_6zBaseTaskTests.test_context_6d s%f--            %'' ##DDFF++D))$//C JJLLLLDJJLLLL s+++++s 2A??BcJtj}t} |||}||||||dS#|wxYwr )r rrrLrnrget_coror@)r-rGrKrbs r test_get_corozBaseTaskTests.test_get_coro s%''!## ==t,,D  # #D ) ) ) MM$--//4 0 0 0 JJLLLLLDJJLLLLs AB B")rEN)vr2r3r4rJrPrLrRrWrcrsrvrrrrrrrrrrrrrrr rrr%r3r:rNrZrorur|rrrrrrrrrrrrrrrrrrrrr rrrr#r2r7r;rDrJrOrRrVr\rermrprtrrrrrrrrrrrrrrrrrrrrrrrrpatchrr rrr$r)r+r.r0r5r:rIrRrZrgrkrorrrrs@rrDrDWs! D FPPPP000EEEEE 222 = = = A A A       / / /"+++>!!!*!!!*--- (((///81S1S1Sf)))$((( + + +@@@ :+++@0(((TgggR%%%* @ @ @D @ @ @D3338:::0 % % % ' ' ''''((((.(((<%%%(%%%&")")")HOOO6666666:!N!N!NF+++""": J J J   666:&&&0666:666<222@666866662220%&%&%&N"6"6"6H<<<$(((6(((0)))$    ( ( (111,+++81118)))""&&&<222@GGG" & & & ' ' ' @ @ @@@@6,,,>###4"""...+++VVV""" ###0 2 2 2***"""" " " " " " "      ("("("TTZ,----.-- + + +555@)))V - - -TZ,-->>.->0 * * * + + + A A A - - - - - -. - - -D)))6,,,8,,,8,,,8rrDc|j}|j}|||SGdd}Gdd||}Gdd||}d}||_||_||_d|_|S)Nc(eZdZfdZfdZxZS)(add_subclass_tests..CommonFuturecntjd|_tj|i|dS)NcdSrerrrrrUzCadd_subclass_tests..CommonFuture.__init__.. sr) collections defaultdictcallsrVrr}s rrz1add_subclass_tests..CommonFuture.__init__ s9$0;;DJ EGG d -f - - - - -rc`|jdxxdz cc<tj|i|S)Nrr)r{rVrr}s rrz:add_subclass_tests..CommonFuture.add_done_callback s> J* + + +q 0 + + +,577,d=f== =rrrs@r CommonFuturerv sQ . . . . . > > > > > > > > >rr}ceZdZdS) add_subclass_tests..TaskNr2r3r4rrrrJr  rrJceZdZdS)"add_subclass_tests..FutureNrrrrrPr rrrPcjfd}|j}j|}|dt |jddit jddidS)NrOcRKjfdd{VS)Nc.dSNrrrsrrUzYadd_subclass_tests..test_subclasses_ctask_cfuture..func.. sv(>(>r)rGrY)rr-srrzGadd_subclass_tests..test_subclasses_ctask_cfuture..func s9 I   > > > > ? ? ?999999 rrrr)rPrGrJrnr^dictr{)r-rrbrrs` @rtest_subclasses_ctask_cfuturez9add_subclass_tests..test_subclasses_ctask_cfuture skktyk))      yydiy00--d33 (((     ! $ & & &  OO ! $ & & & & &r)rJrPrr )clsBaseTask BaseFuturer}rJrPrs radd_subclass_testsr sxHJ:- >>>>>>>>     |X        z   &&&,CHCJ)FC% &*C" JrceZdZdZdZdS)SetMethodsTestc"t|j}tjx|j_}d}|}||j|}||d||j |d| |j ddd}| tjd5|#1swxYwY|dS)Nc>Ktjdd{VdSNrLr)r*rrrrz@SetMethodsTest.test_set_result_causes_invalid_state..foo --$$ $ $ $ $ $ $ $2rrrrostep\(\): already done)r#rPrrrGcall_exception_handlerrLrr^rnassert_called_oncer(rr InvalidStateErrorr@)r-rP exc_handlerrrKrbr%s r$test_set_result_causes_invalid_statez3SetMethodsTest.test_set_result_causes_invalid_state s-d"9=D (;   suu}}TY--$'''  I ( ( . .     &&(((#A&q)+6  # #G$=$=??  I         s-C00C47C4cGddt}t|j}tjx|j_}d}|}||j|}|||| |5|j |dddn #1swxYwY| |j ddd}| tjd5|#1swxYwY|dS)NceZdZdS)ESetMethodsTest.test_set_exception_causes_invalid_state..MyExcNrrrrMyExcr s Drrc>Ktjdd{VdSrr*rrrrzCSetMethodsTest.test_set_exception_causes_invalid_state..foo rrrror)rr#rPrrrGrrLrsrlrnrr(rr rr@)r-rrPrrrKrbr%s r'test_set_exception_causes_invalid_statez6SetMethodsTest.test_set_exception_causes_invalid_state s     I   d"9=D (;   suu}}TY--T5577+++   u % % / / I ( ( . . . / / / / / / / / / / / / / / / &&(((#A&q)+6  # #G$=$=??  I         s$"C  C C !D$$D(+D(N)r2r3r4rrrrrrr s20rr_CFuture_CTaskzrequires the C _asyncio modulecheZdZeeddZeeddZej dZ dZ dS)CTask_CFuture_TestsrNrctjtd}d}||j|}|j||}t dD]@}|||j|j|A|||z dddS)Ngettotalrefcountc KdSr rrrrrKz@CTask_CFuture_Tests.test_refleaks_in_task___init__..coro rfrrrOrr))delta) r get_attributerDrLrGrnrrrS)r-rrKrb refs_beforerQs rtest_refleaks_in_task___init__z2CTask_CFuture_Tests.test_refleaks_in_task___init__ s"06HII   }}TY// $$T***&&(( s / /A MM$$&&tyM 1 1 1 I ( ( . . . . //11K?"MMMMMrcd}||j|}|j||t5|`ddddS#1swxYwYdS)Nc KdSr rrrrrKzHCTask_CFuture_Tests.test_del__log_destroy_pending_segfault..coro rfr)rLrGrnrlAttributeError_log_destroy_pendingrs r&test_del__log_destroy_pending_segfaultz:CTask_CFuture_Tests.test_del__log_destroy_pending_segfault s   }}TY// $$T***   ~ . . * *) * * * * * * * * * * * * * * * * * *sA++A/2A/) r2r3r4getattrrrJrrPr refcount_testrrrrrrr sk 75(D ) )D WWj$ / /F  N N N*****rrcBeZdZeeddZeeddZdS)CTask_CFuture_SubclassTestsrNr)r2r3r4rrrJrrPrrrrr s6 75(D ) )D WWj$ / /FFFrrc6eZdZeeddZejZdS)CTaskSubclass_PyFuture_TestsrN r2r3r4rrrJr _PyFuturerPrrrrr# s+ 75(D ) )D  FFFrrc6eZdZeeddZejZdS)PyTask_CFutureSubclass_TestsrN) r2r3r4rrrPr_PyTaskrJrrrrr, s* WWj$ / /F =DDDrrc6eZdZeeddZejZdS)CTask_PyFuture_TestsrNrrrrrr5 s+ 75(D ) )D  FFFrrc6eZdZejZeeddZdS)PyTask_CFuture_TestsrN) r2r3r4rrrJrrrPrrrrr= s* =D WWj$ / /FFFrrc*eZdZejZejZdS)PyTask_PyFuture_TestsN r2r3r4rrrJrrrPrrrrrE s =D  FFFrrc*eZdZejZejZdS)PyTask_PyFuture_SubclassTestsNrrrrrrL s =D  FFFrrceZdZdZdS)CTask_Future_TestscGddtj}fd}tj|_ ||j|jdjd|j|}|j|}|jn#|jwxYw| |ddS)Nc$eZdZedZdS)+CTask_Future_Tests.test_foobar..Futctr )rr,s rrz4CTask_Future_Tests.test_foobar..Fut.get_loopX s$$rN)r2r3r4propertyrrrrrrW s-  % %X % % %rrcKd{VdSrrrsrrKz,CTask_Future_Tests.test_foobar..coro\ sIIIIIII6rrOrLrr) r rPrrGrCrrrnr@r^)r-rrKrbrrs @r test_foobarzCTask_Future_Tests.test_foobarV s % % % % %'. % % %      *,,  #49%%%C I cna 8 8 89((00D)..t44C IOO    DIOO     f%%%%%s A.CCN)r2r3r4rrrrrrR s#&&&&&rrcZeZdZdZdZdZdZdZdZdZ dZ dZ dZ dZ d Zd Zd ZdS) BaseTaskIntrospectionTestsNcnGfdd}|}tj|tjt |||tj|h||dS)Nc0eZdZefdZdZdS)BBaseTaskIntrospectionTests.test__register_task_1..TaskLikecSr rrQs rrzHBaseTaskIntrospectionTests.test__register_task_1..TaskLike._loopt s rcdSryrr,s rrzGBaseTaskIntrospectionTests.test__register_task_1..TaskLike.donex urN)r2r3r4rrrrOsrTaskLikers sG     X      rrrrr^r rr_register_task_unregister_taskr-rrbrGs @rtest__register_task_1z0BaseTaskIntrospectionTests.test__register_task_1r s          xzzy{{ *400#%%888 D!!! *4004&999 d#####rcnGfdd}|}tj|tjt |||tj|h||dS)Nc eZdZfdZdZdS)BBaseTaskIntrospectionTests.test__register_task_2..TaskLikecSr rrQs rrzKBaseTaskIntrospectionTests.test__register_task_2..TaskLike.get_loop  rcdSryrr,s rrzGBaseTaskIntrospectionTests.test__register_task_2..TaskLike.done rrNr2r3r4rrrOsrrr s=          rrrrs @rtest__register_task_2z0BaseTaskIntrospectionTests.test__register_task_2 s          xzzy{{ *400#%%888 D!!! *4004&999 d#####rcGfdd}|}tj|tjt |||tjt ||dS)Nc eZdZfdZdZdS)BBaseTaskIntrospectionTests.test__register_task_3..TaskLikecSr rrQs rrzKBaseTaskIntrospectionTests.test__register_task_3..TaskLike.get_loop rrcdSr?rr,s rrzGBaseTaskIntrospectionTests.test__register_task_3..TaskLike.done strNrrOsrrr s=          rrrrs @rtest__register_task_3z0BaseTaskIntrospectionTests.test__register_task_3 s          xzzy{{ *400#%%888 D!!! *400#%%888 d#####rcHtj}tj}|tj|||||tj|||||dSr )rrrr r6 _enter_taskr _leave_taskr-rbrGs rtest__enter_taskz+BaseTaskIntrospectionTests.test__enter_task sy{{y{{ '.t44555 t$$$ g*400$777 t$$$$$rctj}tj}tj}||||t5|||dddn #1swxYwY|t j|||||dSr ) rrrrlrrr r6rr-rrrGs rtest__enter_task_failurez3BaseTaskIntrospectionTests.test__enter_task_failure   y{{ u%%%   | , , * *   T5 ) ) ) * * * * * * * * * * * * * * * g*400%888 u%%%%%*B  BBctj}tj}|||||||t j|dSr )rrrrrr r6rs rtest__leave_taskz+BaseTaskIntrospectionTests.test__leave_task siy{{y{{ t$$$ t$$$ '.t4455555rctj}tj}tj}||||t5|||dddn #1swxYwY|tj|||||dSr ) rrrrlrrrr r6rs rtest__leave_task_failure1z4BaseTaskIntrospectionTests.test__leave_task_failure1 rrc0tj}tj}|t5|||dddn #1swxYwY|t j|dSr )rrrlrrrr r6rs rtest__leave_task_failure2z4BaseTaskIntrospectionTests.test__leave_task_failure2 sy{{y{{   | , , ) )   T4 ( ( ( ) ) ) ) ) ) ) ) ) ) ) ) ) ) ) '.t4455555sA$$A(+A(c$tj}tjfd|_|||||t jtdS)NcSr rrOsrrUzBBaseTaskIntrospectionTests.test__unregister_task.. sr) rrrrrr^r rrrs @rtest__unregister_taskz0BaseTaskIntrospectionTests.test__unregister_task syy{{y{{$   D!!! d### *400#%%88888rctj}tj}|||t j|t dSr )rrrr^r rrrs r$test__unregister_task_not_registeredz?BaseTaskIntrospectionTests.test__unregister_task_not_registered sWy{{y{{ d### *400#%%88888r)r2r3r4rrrrrrrrrrrrrrrrrrrl sNKK$$$"$$$ $$$ %%%&&&666&&&66699999999rrceZdZeejZeejZeej Z eej Z dS)PyIntrospectionTestsN) r2r3r4 staticmethodr_py_register_taskr_py_unregister_taskr_py_enter_taskr_py_leave_taskrrrrrr sW!\%"9::N#|E$=>>,u344K,u344KKKrr_c_register_taskceZdZeedrBeejZeejZ eej Z eej Z dSdxZxZ xZ Z dS)CIntrospectionTestsrN)r2r3r4rjrrrr_c_unregister_taskr _c_enter_taskr _c_leave_taskrrrrrr swu())M%e&<=='<(@AA"l5#677 "l5#677 HLLL)LK+++rrc6eZdZfdZdZdZdZdZxZS)BaseCurrentLoopTestscttj|_||jdSr rVrWr rrGrr[s rrWzBaseCurrentLoopTests.setUp @  *,,  DI&&&&&rctr )NotImplementedErrorrs rrLzBaseCurrentLoopTests.new_task s!!rc`|tj|jdSrN)rr r6rGr,s r!test_current_task_no_running_loopz6BaseCurrentLoopTests.test_current_task_no_running_loop s, '.DI>>>?????rc|td5tjddddS#1swxYwYdS)Nzno running event loop)rrr r6r,s r*test_current_task_no_running_loop_implicitz?BaseCurrentLoopTests.test_current_task_no_running_loop_implicit s  # #L2I J J # #  " " " # # # # # # # # # # # # # # # # # #=AAcfd}|jt jjdS)NcKtjjtjdtjdSrN)rr r6rGrasrrKzGBaseCurrentLoopTests.test_current_task_with_implicit_loop..coro sm MM'.DI>>> E E E MM'.t44d ; ; ; MM'.00$ 7 7 7 7 7rrO)rLrGrnrr r6rs` @r$test_current_task_with_implicit_loopz9BaseCurrentLoopTests.test_current_task_with_implicit_loop s{ 8 8 8 8 8 8 }}TTVV$$ $$T*** '.DI>>>?????r) r2r3r4rWrLrrrrrs@rr r  s~''''' """@@@### @ @ @ @ @ @ @rr ceZdZdZdS)PyCurrentLoopTestsc8tj||jSrN)rrrGrs rrLzPyCurrentLoopTests.new_task s}T 2222rNr2r3r4rLrrrrr s#33333rrceZdZdZdS)CCurrentLoopTestscLttd||jS)NrrO)rrrGrs rrLzCCurrentLoopTests.new_task s#'wuh''49====rNrrrrrr s#>>>>>rrc4eZdZdZejdZdS)GenericTaskTestsct|ttjtjdSr )ri issubclassr rJrPr,s rtest_future_subclassz%GenericTaskTests.test_future_subclass s(  7<@@AAAAArc ddl}ddl}ddl} ddl}dS#t$r|dYdSwxYw#t$r|dYdSwxYw)Nrz_asyncio module is missingzC modules are not available) _functools_json_pickle_asyncio ImportErrorrskipTest)r-r'r(r)r*s rtest_asyncio_module_compiledz-GenericTaskTests.test_asyncio_module_compiled s 8     LLL NNN 8 8 8 8 6777777 8  9 9 9 MM7 8 8 8 8 8 8 9s ;88AAN)r2r3r4r%r cpython_onlyr-rrrr"r" sEBBB 88888rr"cHeZdZfdZdZdZdZdZdZdZ dZ xZ S) GatherTestsBasect||_||_||jddS)NF)cleanup)rVrWrXone_looprrr[s rrWzGatherTestsBase.setUp4 s[  **,, ,,.. DM599999rcN|jrtj||jdSdSr )rrrrQs r _run_loopzGatherTestsBase._run_loop: s=k )  "4 ( ( (k ) ) ) ) )rc fdtdD\}}}j|||i|}tj}|||d|dj |j d | |dj| | |gddS)NcBg|]}jSrr3rZrrQr-s rrz2GatherTestsBase._check_success..? s'CCCQ4=..00CCCrrrrF)rrr)r_gather wrap_futuresr MockCallbackrrr5r3r^rr.rassert_called_once_withr)r-r~rr rrcbs` r_check_successzGatherTestsBase._check_success> s7CCCC%((CCC1adlD--aA66A&AA  $ & & b!!! Q Q t}%%% E*** $$$ Q t}%%% ""3''' yyy11111rcZ||ddS)NFrr?r,s r test_successzGatherTestsBase.test_successM s1  e44444rc2|ddS)NTrrAr,s rtest_result_exception_successz-GatherTestsBase.test_result_exception_successQ s d33333rc fdtdD\}}}}}j|||||}tj}||t }|d|| j  | | ||||d||t#|dS)NcBg|]}jSrr8r9s rrz6GatherTestsBase.test_one_exception..U 'III14466IIIrr_rr)rr:r;rr<rrrrsr5r3rirr=rrorkr) r-rr rrerr>r%s ` rtest_one_exceptionz"GatherTestsBase.test_one_exceptionT s?IIIIaIII 1aAdlD--aAq!<<=  $ & & b!!!!! Q  t}%%%  ### ""3''' cmmoos+++ Q    ''' rcDfdtdD\}}}}j||||ddi}tj}||t }t}|d| ||d j  | | | j | |||dd||gdS)NcBg|]}jSrr8r9s rrz:GatherTestsBase.test_return_exceptions..g s'FFFdm1133FFFrrTrr)rr:r;rr<rrrrrsr5r3r.rrir=r^r) r-rr rrrr>r%exc2s ` rtest_return_exceptionsz&GatherTestsBase.test_return_exceptionsf srFFFFU1XXFFF 1adlD--aAq993-133  $ & & b!!!!!~~ Q  Q t}%%% $$$  t}%%%  ### ""3''' 1c4'899999rcdd}tdd|\}}}||dtd|dd\}}}||dtd|dd\}}}||d tdd|dd\}}}||dtdd d d|\}}}||d dS) N )zimport asyncio.coroutinesz*print(asyncio.coroutines._is_debug_mode())z-Ez-csFalse)PYTHONASYNCIODEBUG PYTHONDEVMODE1sTruez-Xdev)joinr r^rstrip)r-codestsstdoutstderrs rtest_env_var_debugz"GatherTestsBase.test_env_var_debugy ssyy:;; /tT4@@VV (333.tTBD=?AAAVV (333.tTBE=?AAAVV '222.tT4BE=?AAAVV (333/tT5/3T;;VV '22222r) r2r3r4rWr5r?rBrDrIrNr\rrs@rr0r02 s::::: ))) 2 2 2555444$:::&3333333rr0cDeZdZdZdZdZdZdZdZdZ dZ d Z d S) FutureGatherTestsc|Sr r)r-rs rr;zFutureGatherTests.wrap_futures src$tj|i|Sr r r)r-r$r~s rr:zFutureGatherTests._gather s~t.v...rc|td5tjddddS#1swxYwYdS)Nr)rrr rr,s r,test_constructor_empty_sequence_without_loopz>FutureGatherTests.test_constructor_empty_sequence_without_loop s  # #L2I J J   N                     rcd}|j|}||tj||j|j||j|| | | gdS)Nc,KtjSr rarrrrzRFutureGatherTests.test_constructor_empty_sequence_use_running_loop..gather s>## #r) r3rnr`r rPrrr5rirr^r)r-rrs r0test_constructor_empty_sequence_use_running_loopzBFutureGatherTests.test_constructor_empty_sequence_use_running_loop s $ $ $m..vvxx88 c7>222 ci/// t}%%%  ### r*****rctj|j|tjdtj}||tj||j|j| |j| | | | gdSr )r rr3rrr`rPrrr5rirr^r)r-rs r/test_constructor_empty_sequence_use_global_loopzAFutureGatherTests.test_constructor_empty_sequence_use_global_loop st}--- .555n c7>222 ci/// t}%%%  ### r*****rc|j}|j}|t5t j||ddddS#1swxYwYdSr )r3rZrrlrr r)r-rrs r%test_constructor_heterogenous_futuresz7FutureGatherTests.test_constructor_heterogenous_futures s}**,,,,..   z * * ' ' N4 & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's A00A47A4cfdtdD}tj|}|jjj|tj|}|jjj|dS)NcBg|]}jSr)rrZr9s rrzIFutureGatherTests.test_constructor_homogenous_futures.. s'FFFDO1133FFFrr) rr rrrrr5r.r)r-childrenrs` r#test_constructor_homogenous_futuresz5FutureGatherTests.test_constructor_homogenous_futures sFFFFU1XXFFFnh' ci111 t''' $$$nh' ci111 t''' $$$$$rc6fdtdD\}}}}}tj|||||}tj}|||d|j  | | | ||tj|d||t'|dS)NcBg|]}jSrr8r9s rrz;FutureGatherTests.test_one_cancellation.. rGrr_rr)rr rrr<rrrkr5r3rirr=r.r9r`rormrsr)r-rr rrrHrr>s` rtest_one_cancellationz'FutureGatherTests.test_one_cancellation sCIIIIaIII 1aAnQ1a++  $ & & b!!! Q   t}%%%  ### ""3''' ))) cmmoow/EFFF Q    ''' rc fdtdD\}}}}}}tj||||||d}tj}|||dt} || |  j  | |d| t} || j |} | dtj| dtjdx| d<| d<| d| ddd| g||dS) NcBg|]}jSrr8r9s rrzLFutureGatherTests.test_result_exception_one_cancellation.. s7/// !!M7799///rrTrrrrrL)rr rrr<rrrrsrkr5r3r.rrrnr`rmr^r=) r-rr rrrHrrr>zderters ` r&test_result_exception_one_cancellationz8FutureGatherTests.test_result_exception_one_cancellation s////%*1XX///1aAqnQ1aAFFF  $ & & b!!! Q!!    t}%%% $$$ Q  nn m..s33 c!fg&<=== c!fg&<===AQ q#tQc:;;; ""3'''''rN) r2r3r4r;r:rcrfrhrjrnrqrvrrrr^r^ s///+++ + + +''' % % %$(((((rr^cDeZdZdZdZdZdZdZdZdZ dZ d Z d S) CoroutineGatherTestscXg}|D]$}|fd}||%|S)NcK|d{VSr rrs rrKz/CoroutineGatherTests.wrap_futures..coro s yyyyyy r)r/)r-rcorosrrKs rr;z!CoroutineGatherTests.wrap_futures sM ! !C" ! ! ! ! LL  rcVfd}|j|S)Nc*KtjiSr ra)r$r~srrKz*CoroutineGatherTests._gather..coro s>42622 2r)r3rn)r-r$r~rKs `` rr:zCoroutineGatherTests._gather s> 3 3 3 3 3 3}//777rc.d}|}||j|}||j|td5t j||ddddS#1swxYwYdS)Nc KdSrrrrrrKz@CoroutineGatherTests.test_constructor_without_loop..coro rrr)rr@rrr r)r-rKgen1gen2s rtest_constructor_without_loopz2CoroutineGatherTests.test_constructor_without_loop s   tvv  ###tvv  ###  # #L2I J J ' ' N4 & & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' 's'B  BBcd}||fd}|j|}||j|j|j|dS)Nc KdSrrrrrrKzDCoroutineGatherTests.test_constructor_use_running_loop..coro rrc2KtjSr ra)rrsrrzFCoroutineGatherTests.test_constructor_use_running_loop..gather s>$-- -r)r3rnrr)r-rKrrrrs @@r!test_constructor_use_running_loopz6CoroutineGatherTests.test_constructor_use_running_loop s   tvvtvv . . . . . .m..vvxx88 ci/// ((-----rcDd}tj|j|tjd|}|}tj||}||j|j|j|dS)Nc KdSrrrrrrKzCCoroutineGatherTests.test_constructor_use_global_loop..coro rr)r rrrrrrrn)r-rKrrrs r test_constructor_use_global_loopz5CoroutineGatherTests.test_constructor_use_global_loop s   t/// .555tvvtvvnT4(( ci111 **3/////rcd}|d}||||d|}||j||gddS)Nc K|Sr rrs rrKz.coro% rrrdef)rrrr)r:r5r3r^r)r-rKrrs rtest_duplicate_coroutinesz.CoroutineGatherTests.test_duplicate_coroutines$ s|    DKKll1aea00 t}%%% 'C'C'CDDDDDrcd|jfd}tj||jtj||jdfd}tj||j}t j|j|||tj 5|j |dddn #1swxYwY| | | | t j|j| ddS)Nrc&Kd{Vdz dSrrrsrrz?CoroutineGatherTests.test_cancellation_broadcast..inner1 rrrOcPKtjd{Vdz dSrra)rrgathererrsrrz?CoroutineGatherTests.test_cancellation_broadcast..outer: s6~ff55HNNNNNNN SLEEEr)r3rZr rrrrirkrlrmrnr.r9r^) r-rrrrrrrrs @@@@@rtest_cancellation_broadcastz0CoroutineGatherTests.test_cancellation_broadcast, s,,..       &uuwwT]CCC&uuwwT]CCC          !%%'' > > >t}---  ###   w5 6 6 0 0 M , ,Q / / / 0 0 0 0 0 0 0 0 0 0 0 0 0 0 0 **+++ ((**+++ ((**+++ ((**+++t}--- """""s9D  D$'D$cd|j|jfd}tj||j}t j|jdt j|jdt j|j||tdS)Nc4K|d{Vtd)Nzshould not be ignoredrrs rrz:CoroutineGatherTests.test_exception_marking..innerO s&GGGGGGG677 7rcfKtjd{VdSr ra)rr rsrrz:CoroutineGatherTests.test_exception_marking..outerV sA.q558844 4 4 4 4 4 4 4 4 4rrO) r3rZr rrrrr`ror)r-rrrr rs @@@rtest_exception_markingz+CoroutineGatherTests.test_exception_markingL s 8 8 8 M ' ' ) ) M ' ' ) ) 5 5 5 5 5 5 5  !%%'' > > >t}--- Tt}--- Tt}--- akkmm\:::::rc|tjd5d}|d}|t5||idddn #1swxYwY||j|jjddddS#1swxYwYdS)Nz8asyncio.base_events.BaseEventLoop.call_exception_handlerc K|Sr rrs rrKz2CoroutineGatherTests.test_issue46672..coroe s rr) rrsrlrr:r5r3rassert_not_called)r-rKrs rtest_issue46672z$CoroutineGatherTests.test_issue46672a sS Z F  E E   U A""9-- $ $ Q### $ $ $ $ $ $ $ $ $ $ $ $ $ $ $ NN4= ) ) ) M 0 B B D D D E E E E E E E E E E E E E E E E E Es4)B1A! B1!A% %B1(A% );B11B58B5N) r2r3r4r;r:rrrrrrrrrrrxrx s888 ''' . . . 0 0 0EEE###@;;;* E E E E ErrxcTeZdZdZfdZd dZ d dZdZdZd Z d Z d Z xZ S)RunCoroutineThreadsafeTestsz/Test case for asyncio.run_coroutine_threadsafe.cttj|_||jdSr rr[s rrWz!RunCoroutineThreadsafeTests.setUps rrFcKtjdd{V|rtd|rEtj|jtjdd{V||zS)z"Wait 0.05 second and return a + b.r>NFail!r)r r+rr6rGrk)r-rr rrks rr(zRunCoroutineThreadsafeTests.addx smD!!!!!!!!!  (w'' '  #   + + 2 2 4 4 4-"" " " " " " " "1u rNc|dd||}tj||j}|r |j|jd |||p|SS#|p|wwxYw)z$Run add coroutine in the event loop.rr)rrkN) r(r run_coroutine_threadsaferGcall_soon_threadsafer<rrrk)r-rrkr< advance_cororKrs rtargetz"RunCoroutineThreadsafeTests.target sxx14x771$ BB  < I * *49d ; ; ; -==)) KKMM ,V]]____ , ,FKKMM ,V]]____ , ,s B,Cc|jd|j}|j|}||ddS)z9Test coroutine submission from a thread to an event loop.Nr)rGrun_in_executorrrnr^)r-rrs rtest_run_coroutine_threadsafez9RunCoroutineThreadsafeTests.test_run_coroutine_threadsafe sL**4==--f55 #####rc |jd|jd}|t5}|j|dddn #1swxYwY|d|jjdS)z]Test coroutine submission from a thread to an event loop when an exception is raised.NTr) rGrrrlrrnr1ror$)r-r exc_contexts r,test_run_coroutine_threadsafe_with_exceptionzHRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_with_exception s**4dCC   | , , 1 I ( ( 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 g{49:::::sA##A'*A'cfd}jd|}tj5j|dddn #1swxYwYt jjtjjD])} | *dS)zZTest coroutine submission from a thread to an event loop when a timeout is raised.c0dS)Nrrrr,srrUzXRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_with_timeout.. s4;;q;11rN) rGrrlr rFrnrrrrir)r-rarrbs` r*test_run_coroutine_threadsafe_with_timeoutzFRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_with_timeout s2111**4::   w3 4 4 1 1 I ( ( 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1ty)))%di00 ) )D OODIIKK ( ( ( ( ) )sA((A,/A,cfd}jd|}tj5j|ddddS#1swxYwYdS)z\Test coroutine submission from a thread to an event loop when the task is cancelled.c0dS)NTr@rr,srrUzZRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_task_cancelled.. s4;;d;33rN)rGrrlr rmrn)r-rars` r,test_run_coroutine_threadsafe_task_cancelledzHRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_task_cancelled s4333**4::   w5 6 6 1 1 I ( ( 0 0 0 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1 1sA))A-0A-cd}jdfd}tj}j|jjjj|t5}j |dddn #1swxYwY t|j d|j\\}}} |d|jdS)zjTest coroutine submission from a thread to an event loop when the task factory raise an exception.ctr ) NameError)rGrKs r task_factoryzfRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_task_factory_exception..task_factory sOrNc0dS)NT)rrr,srrUzbRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_task_factory_exception.. s$++4+88rrro)rGrrr<rrrYget_task_factoryrlrrnr^rcall_args_listr(ro)r-rrrarrGr'r~s` r4test_run_coroutine_threadsafe_task_factory_exceptionzPRunCoroutineThreadsafeTests.test_run_coroutine_threadsafe_task_factory_exception s|   i'' 8888::*,, ''111  2 2244 6 6 6 ""<000  y ) ) .[ I ( ( - - - . . . . . . . . . . . . . . . X455q999"*"4w -{/DEEEEEs;C""C&)C&)FF)FFNF) r2r3r4__doc__rWr(rrrrrrrrs@rrrp s99''''' 8<!----"$$$ ;;; ) ) )111FFFFFFFrrc.eZdZfdZfdZdZxZS) SleepTestscttj|_||jdSr rr[s rrWzSleepTests.setUp rrc|jd|_tdSr rGr@rVtearDownr[s rrzSleepTests.tearDown 8   rcdfdfd}j|ddS)Nrc|z dSr r)rWrs r inc_resultz.SleepTests.test_sleep_zero..inc_result s cMFFFrcKjddtjddd{V}d|dS)Nrrr)r)rGrYr^r r+)rWrrr-s rrKz(SleepTests.test_sleep_zero..coro s I   A . . .   VQ ' ' ' a333333333C   VQ ' ' ' JsOOOOOr )rGrnr^)r-rKrrs` @@rtest_sleep_zerozSleepTests.test_sleep_zero s             $$TTVV,,, $$$$$r)r2r3r4rWrrrrs@rrr s`'''''  %%%%%%%rrc(eZdZfdZfdZxZS)CompatibilityTestscttj|_||jdSr rr[s rrWzCompatibilityTests.setUp rrc|jd|_tdSr rr[s rrzCompatibilityTests.tearDown rr)r2r3r4rWrrrs@rrr sQ''''' rr__main__)F)?rry contextlibrG functoolsr{rrUrrDtextwraprunittestrtypesrr rrrtest.test_asynciorrrr test.support.script_helperr rrr r(r*r6rDrr skipUnlessrjTestCaserrrrrrrrrrrrr rrr"r0r^rxrrrr2rrrrrs 111111777777(((    ? ? ? ? ( ( (                 q$q$q$q$q$q$q$q$hI777t22222222jWWWj11.WUH--577*****-$-**77*8WWWj11.WUH--57700000-1D00770 WWUH--577=*2E77 WWWj11577=*2E77 WWUH--577=**=77 WWWj1157700000=**=00770 M>&/M:3F WWUH--577&&&&&,&&77&0m9m9m9m9m9m9m9m9`55555:.0J555WWU$677577MMMMM*-/IMM77M@@@@@@@@:33333-z/B333 WWUH--577>>>>>,j.A>>77> 88888z*8880c3c3c3c3c3c3c3c3LY(Y(Y(Y(Y()<Y(Y(Y(xyEyEyEyEyE?J,?yEyEyEx_F_F_F_F_F*"5_F_F_FD%%%%%$%%%:     ,    zHMOOOOOr