2hhr<$SSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKrSSKJ r SSKJ r SSK J r SrSr"SS\R 5r"S S \R$5r"S S \5r"S S\5r\S:Xa\R."5 gg)N)utils)mock)patchc0[R"S5 gN)asyncioset_event_loop_policyG/opt/python-3.13.8/usr/lib/python3.13/test/test_asyncio/test_runners.pytearDownModuler s !!$'r c.[R"5 gr)_threadinterrupt_mainr r r interrupt_selfrs r c,\rSrSrSrSrSrSrSrg) TestPolicycXlSUlgr) loop_factoryloop)selfrs r __init__TestPolicy.__init__s( r c[er) RuntimeErrorrs r get_event_loopTestPolicy.get_event_loopsr c"UR5$rrrs r new_event_loopTestPolicy.new_event_loop s  ""r cUbXlggrr)rrs r set_event_loopTestPolicy.set_event_loop#s  I r )rrN) __name__ __module__ __qualname____firstlineno__rrr"r&__static_attributes__r r r rrs#r rc:^\rSrSrSrU4SjrU4SjrSrU=r$)BaseTest*cN^[R"5m[R"5Tl[R"5TlSTR l[R"5TlSTRRlSTl U4SjnUTl T$)Nr Fc># STlg7fNT)shutdown_ag_runr%sr shutdown_asyncgens-BaseTest.new_loop..shutdown_asyncgens6s#'D s ) r BaseEventLooprMock_process_events_write_to_self return_value _selectorselectr3r4)rr4rs @r new_loopBaseTest.new_loop,st$$&#yy{"iik+/(-/*$ ("4 r cx>[TU]5 [UR5n[R "U5 gr)supersetUprr=rr rpolicy __class__s r rABaseTest.setUp<s(  DMM*%%f-r c.>[R"5nURbNURURR 55 URURR 5 [R "S5 [TU]!5 gr) rget_event_loop_policyr assertTrue is_closedr3r r@tearDownrBs r rJBaseTest.tearDownBsc..0 ;; " OOFKK113 4 OOFKK77 8%%d+ r r ) r(r)r*r+r=rArJr, __classcell__rDs@r r.r.*s . r r.c\\rSrSrSrSrSrSrSrSr Sr S r S r S r S rS rSrg)RunTestsLc`SnUR[R"U"55S5 g)NcL# [R"S5IShvN gN7fNrr/rsleepr r r main.RunTests.test_asyncio_run_return..mainO--" " " # $"$r/) assertEqualrrunrrVs r test_asyncio_run_return RunTests.test_asyncio_run_returnNs$  TV,b1r cSnUR[S5 [R"U"55 SSS5 g!,(df  g=f)Nc`# [R"S5IShvN [S5eN7f)Nrspam)rrU ValueErrorr r r rV.RunTests.test_asyncio_run_raises..mainVs'--" " "V$ $ #s .,.ra)assertRaisesRegexrbrr[r\s r test_asyncio_run_raises RunTests.test_asyncio_run_raisesUs3 % # #J 7 KK 8 7 7s ? A cSS1HPnURUS9 UR[S5 [R"U5 SSS5 SSS5 MR g!,(df  N=f!,(df  Mu=f)Ncgrr r r r 5RunTests.test_asyncio_run_only_coro..^sTr )obja coroutine was expected)subTestrdrbrr[)ros r test_asyncio_run_only_coro#RunTests.test_asyncio_run_only_coro]sb\"A!$**:+EG AG%$#GG%$s"A,AA, A) %A,, A; c"^U4Sjn[R"U"S5SS9 [R"U"S5SS9 [R"SS5 [R"U"S55 [R"U"S5SS9 SSS5 [R"SS5 [R"U"S5SS9 [R"U"S55 SSS5 g!,(df  Ng=f!,(df  g=f)Ncx># [R"5nTRUR5U5 g7fr)rrassertIs get_debug)expectedrrs r rV-RunTests.test_asyncio_run_debug..maines)))+D MM$..*H 5s7:FdebugTz!asyncio.coroutines._is_debug_modecgr2r r r r rj1RunTests.test_asyncio_run_debug..ksTr cg)NFr r r r rjr{nsUr )rr[rrr\s` r test_asyncio_run_debugRunTests.test_asyncio_run_debugds 6  DKu- DJd+ ZZ;\ J KKT # KKU 5 1KZZ;] K KKT $ / KKU $L KK JL Ks8C/.8D/ C= Dc^U4SjmUR[S5 [R"T"55 SSS5 g!,(df  g=f)Nc># T"5n[R"U5 UR5 g!UR5 f=f7fr)rr[close)cororVs r rV9RunTests.test_asyncio_run_from_running_loop..mainss06D  D!  sA3AAAzcannot be called from a running)rdrrr[r\s @r "test_asyncio_run_from_running_loop+RunTests.test_asyncio_run_from_running_looprs?  # #L$EG KK GGGs A Ac^^SmSmUU4SjnUR[R"U"55S5 URTR 55 g)NcL# [R"S5IShvN gN7f)N皙?rTr r r leftoverARunTests.test_asyncio_run_cancels_hanging_tasks..leftovers--$ $ $rYcD># [R"T"55mg7fN{)r create_task)rlo_tasksr rV=RunTests.test_asyncio_run_cancels_hanging_tasks..mains))(*5Gs r)rZrr[rHdone)rrVrrs @@r &test_asyncio_run_cancels_hanging_tasks/RunTests.test_asyncio_run_cancels_hanging_tasks~sA %  TV,c2  'r cd^^^Sm[R"5mSmUUU4SjnUR[R"U"55S5 UR TR 55 TR[R"S5T[R"[5S.5 g)Nc# [R"S5IShvN gN![Ra SS- gf=f7f)Nrrhr)rrUCancelledErrorr r r rHRunTests.test_asyncio_run_reports_hanging_tasks_errors..leftovers7 mmC((()) A s0A%#%A%AAAAc|># [R"5nTUl[R"T"55mg7fr)rget_running_loopcall_exception_handlerr)rcall_exc_handler_mockrrs r rVDRunTests.test_asyncio_run_reports_hanging_tasks_errors..mains3++-D*?D '))(*5Gs9<rzasyncio.run.*shutdown)messagetask exception) rr7rZrr[rHrassert_called_with test_utils MockPatternMockInstanceOfZeroDivisionError)rrVrrrs @@@r -test_asyncio_run_reports_hanging_tasks_errors6RunTests.test_asyncio_run_reports_hanging_tasks_errorss $     TV,c2  '00!--.FG#223DE2  r c^^^^^SmSm"SS[5mSmUU4SjmUUU4SjnURT5 [R"U"55 SSS5 UR TR 55 UR TR5 URTR5 g!,(df  Nd=f)Nc\rSrSrSrg)SRunTests.test_asyncio_run_closes_gens_after_hanging_tasks_errors..FancyExitr N)r(r)r*r+r,r r r FancyExitrs r rcZ# S7v [R"S5IShvN M%N7fNrhrTr r r fidgetPRunTests.test_asyncio_run_closes_gens_after_hanging_tasks_errors..fidgets'mmA&&&&s +)+c|># T"5mTShvN nM N g![Ra SS- gf=f7f)Nrhr)rr)the_meaning_of_liferspinners r spinNRunTests.test_asyncio_run_closes_gens_after_hanging_tasks_errors..spinsBhG 18-)) A s4<<9<9<c># [R"5n[R"5Ul[R "T"55mTe7fr)rrrr7rr)rrlazyboyrs r rVNRunTests.test_asyncio_run_closes_gens_after_hanging_tasks_errors..mains;++-D*.))+D '))$&1GOsA A) Exception assertRaisesrr[rHr assertIsNoneag_frame assertFalse ag_running)rrVrrrrrs @@@@@r 7test_asyncio_run_closes_gens_after_hanging_tasks_errors@RunTests.test_asyncio_run_closes_gens_after_hanging_tasks_errorss    '     y ) KK *  ' '**+ ++, * )s B66 CcSn[R"5n[R"5Ul[R "U"55 UR URR5 g)NcL# [R"S5IShvN gN7frSrTr r r rV6RunTests.test_asyncio_run_set_event_loop..mainrXrY)rrGrr7r&r[rHcalled)rrVrCs r test_asyncio_run_set_event_loop(RunTests.test_asyncio_run_set_event_loopsK ..0 $  DF --445r c^^"SS5mSnUU4Sjn[R"[U55 TR[R5 [R "U"55 SSS5 g!,(df  g=f)Nc`\rSrSrSrSrSrSr\S5r Sr Sr S r S r S rS rS rg)8RunTests.test_asyncio_run_without_uncancel..Taskc@[R"U4SU0UD6Ulg)Nr)rTask_task)rrrkwargss r rARunTests.test_asyncio_run_without_uncancel..Task.__init__s$\\$DTDVD r c:URR"U0UD6$r)rcancelrargsrs r r?RunTests.test_asyncio_run_without_uncancel..Task.cancelzz(($9&99r c:URR"U0UD6$r)radd_done_callbackrs r rJRunTests.test_asyncio_run_without_uncancel..Task.add_done_callbackszz33TDVDDr c:URR"U0UD6$r)rremove_done_callbackrs r rMRunTests.test_asyncio_run_without_uncancel..Task.remove_done_callbackszz66GGGr c.URR$r)r_asyncio_future_blockingrs r rQRunTests.test_asyncio_run_without_uncancel..Task._asyncio_future_blockingszz:::r c:URR"U0UD6$r)rresultrs r r?RunTests.test_asyncio_run_without_uncancel..Task.resultrr c:URR"U0UD6$r)rrrs r r=RunTests.test_asyncio_run_without_uncancel..Task.doneszz777r c:URR"U0UD6$r)r cancelledrs r rBRunTests.test_asyncio_run_without_uncancel..Task.cancelledzz++T.Task.exceptionrr c:URR"U0UD6$r)rget_looprs r rARunTests.test_asyncio_run_without_uncancel..Task.get_loopzz**D;F;;r c:URR"U0UD6$r)rset_namers r rARunTests.test_asyncio_run_without_uncancel..Task.set_namerr )rN)r(r)r*r+rrrrpropertyrrrrrrrr,r r r rrsK E : E H ; ; : 8 = = < .mains#  --/&&( ( (s 1;9;cJ>TR5nURT5 U$r)r=set_task_factory)rrrs r r"BRunTests.test_asyncio_run_without_uncancel..new_event_loops!==?D  ! !$ 'Kr )rr rrrr[)rrVr"rs` @r !test_asyncio_run_without_uncancel*RunTests.test_asyncio_run_without_uncancels[! <! # TR[R"5T5 g7fr)rZrr)rrsr rV4RunTests.test_asyncio_run_loop_factory..mains   W557 >s'*r!)rr7r=r:rr[assert_called_once_with)rfactoryrVrs` @r test_asyncio_run_loop_factory&RunTests.test_asyncio_run_loop_factory sD))+&*mmo5w# ?  DF1'')r cb^U4Sjn[R"U"5[RS9 g)Nc># [RS:Xa4TR[R"5[R 5 gTR[R"5[R 5 g7f)Nwin32)sysplatformassertIsInstancerrProactorEventLoopSelectorEventLooprsr rV;RunTests.test_loop_factory_default_event_loop..mainsP||w&%%g&>&>&@'B[B[\%%g&>&>&@'B[B[\sA=Br!)rr[ EventLoopr\s` r $test_loop_factory_default_event_loop-RunTests.test_loop_factory_default_event_loops! ]  DF):):;r r N)r(r)r*r+r]rerpr}rrrrrrrr r,r r r rOrOLs@2  %   ( 6#-J 60 d*T$rr r%sr rj1RunnerTests.test_custom_factory..+sr r!)rr7rrrtrrrrs @r test_custom_factoryRunnerTests.test_custom_factory)s=yy{ ^^ 6& MM&//+T 27 6 6s !A A'cSn[R"5nURSURU"555 UR 5nSSS5 UR [ S5 WR 5 SSS5 URWR55 g!,(df  N]=f!,(df  N?=f)NcL# [R"S5IShvN gN7f)NrrrTr r r fRunnerTests.test_run..f/s--" " " #rYrRunner is closed) rrrZr[rrdrrHrI)rr!rrs r test_runRunnerTests.test_run.s ^^    VVZZ_ 5??$D # #    OO   ()   s7B'.B8' B58 Cc[R"5nUR[S5 UR S5 SSS5 SSS5 g!,(df  N=f!,(df  g=f)Nrmr)rrrdrbr[rs r test_run_non_coroRunnerTests.test_run_non_coro?sP ^^ ''* 3   s!A!AA! A A!! A/c [R"5nUR[S5 UR 5R 5nUR U5 SSS5 SSS5 g!,(df  N=f!,(df  g=f)Nrm)rrrdrbr create_futurer[)rrfuts r test_run_futureRunnerTests.test_run_futureGse ^^ ''*oo'557 3   s"A?0A.A?. A< 8A?? B c,[R"5nUR5nUR5 UR [ S5 UR5 SSS5 UR UR55 g!,(df  N.=f)Nr#)rrrrrdrrHrIrs r test_explicit_closeRunnerTests.test_explicit_closePsh!    # #"  OO   ()   s B Bc [R"5nUR5nUR5 UR UR 55 UR5 UR UR 55 gr)rrrrrHrIrs r test_double_closeRunnerTests.test_double_close\sT!   ()   ()r c^/mU4Sjn[R"5nU URU"S55 SSS5 UR[S5 U URU"S55 SSS5 SSS5 UR S/T5 g!,(df  Nc=f!,(df  N;=f!,(df  ND=f)Nc0># TRU5 g7fr)append)argrets r r!4RunnerTests.test_second_with_block_raises..fjs JJsOsrhr#)rrr[rdrrZ)rr!rr8s @r test_second_with_block_raises)RunnerTests.test_second_with_block_raisesgs !  JJqt  # #    1Q4    !c"V   s/BB8B'2B8 B$' B5 1B88 Cc ^[R"SSS9mU4SjnSn[R"5nUR SUR U"S555 UR SUR U"S555 UR SUR U"55R T55 SSS5 g!,(df  g=f)Ncvar)defaultc># TR5n[R"S5IShvN TRU5 U$N7fNr)getrrUset)valoldr>s r r!-RunnerTests.test_run_keeps_context..f}s8((*C--" " " HHSMJ #s*AAAc4# [R"5$7fr) contextvars copy_contextr r r get_context7RunnerTests.test_run_keeps_context..get_contexts++- -srhr:)rI ContextVarrrrZr[rC)rr!rKrr>s @r test_run_keeps_context"RunnerTests.test_run_keeps_contextzs%%fb9   .^^    RAaD!1 2   Q 1Q4 0 1   Q ;= 9 = =d C D   s BC Cc^^SmUU4Sjn[R"5mUR[S5 UR [ [ R"S55 TRU"55 SSS5 SSS5 SSS5 g!,(df  N=f!,(df  N(=f!,(df  g=f)Nc # g7frr r r r g)RunnerTests.test_recursive_run..g c:># TRT"55 g7fr)r[)rRrsr r!)RunnerTests.test_recursive_run..fs JJqsOszcoroutine .+ was never awaitedz7Runner.run() cannot be called from a running event loop) rrassertWarnsRegexRuntimeWarningrdrreescaper[)rr!rRrs @@r test_recursive_runRunnerTests.test_recursive_runs  ^^ &&0++ IIQ JJqsO      s:B6+B%$B;B%B6 B" B%% B3 /B66 Cc^[R"5[R"5LdeU4Sjn[R"5nUR 5R S[5 TR[5 URU"55 SSS5 SSS5 g!,(df  N=f!,(df  g=f)Nc># TR[R5 [R"S5IShvN M N!,(df  O=f[R"5e7frB)rrrrUrsr r2RunnerTests.test_interrupt_call_soon..corosQ""7#9#9:!--****;:((* *s A-AAA AA-r) threadingcurrent_thread main_threadrrr call_laterrrKeyboardInterruptr[rrrs` r test_interrupt_call_soon$RunnerTests.test_interrupt_call_soons'')Y-B-B-DDDD + ^^  OO  ( (n =""#45 46"6 55 s$ :B=B,B=, B: 6B== C c^[R"5[R"5LdeU4Sjn[R"5nUR 5R 5nUR 5RS[5 TR[5 URU"U55 SSS5 TRUR55 SSS5 g!,(df  N6=f!,(df  g=f)Nc># TR[R5 UIShvN SSS5 [R"5eN!!,(df  N%=f7fr)rrr)r+rs r r-RunnerTests.test_interrupt_wait..corosB""7#9#9: ;((* *;:s+ AA A A A A  AAr)rarbrcrrrr*rdrrrer[rHr)rrrr+s` r test_interrupt_waitRunnerTests.test_interrupt_waits'')Y-B-B-DDDD + ^^ //#113C OO  ( (n =""#45 49%6 OOCMMO , 65  s% AC;"C*:'C;* C8 4C;; D cn^[R"5[R"5LdeSmU4Sjn[R"5nUR [R 5 URU"55 SSS5 SSS5 g!,(df  N=f!,(df  g=f)Nc# [R"S5IShvN UR5 [5 gN7frB)rrUrr)rs r subtask:RunnerTests.test_interrupt_cancelled_task..subtasks+--" " " KKM   #s >< >c># [R"T"[R"555 [R"S5IShvN gN7f)N )rr current_taskrU)rpsr r7RunnerTests.test_interrupt_cancelled_task..coros4   (<(<(> ? @--# # #sA A A A)rarbrcrrrrr[)rrrrps @r test_interrupt_cancelled_task)RunnerTests.test_interrupt_cancelled_tasksz'')Y-B-B-DDDD   $^^ ""7#9#9: 46"; :: s$ B&-BB& B# B&& B4ch[R"5[R"5LdeSn[R"5n[ R "[S[S5S9 URU"55 SSS5 SSS5 g!,(df  N=f!,(df  g=f)Nc # g7frr r r r r>RunnerTests.test_signal_install_not_supported_ok..cororTrUsignalz8signal only works in main thread of the main interpreter) side_effect) rarbrcrrrobjectr{rbr[rfs r $test_signal_install_not_supported_ok0RunnerTests.test_signal_install_not_supported_oks'')Y-B-B-DDDD ^^ &N 46"  s$$B#*BB# B B## B1cVSn[R"5n[R"5Ul[R "5nUR U"55 UR U"55 URSURR5 UR5 g)Nc # g7frr r r r r9RunnerTests.test_set_event_loop_called_once..cororTrUrh) rrGrr7r&rr[rZ call_countr)rrrCrs r test_set_event_loop_called_once+RunnerTests.test_set_event_loop_called_oncesr ..0 $ ! 46 46 F11<<= r c^"SS5mU4Sjn[R"5nURU"55nSSS5 URSWR5 g!,(df  N+=f)Nc.^\rSrSrSrU4SjrSrU=r$)ERunnerTests.test_no_repr_is_call_on_the_task_result..MyResulticSUlgrB repr_countrs r rNRunnerTests.test_no_repr_is_call_on_the_task_result..MyResult.__init__s "#r cJ>U=RS- sl[TU] 5$r)rr@__repr__)rrDs r rNRunnerTests.test_no_repr_is_call_on_the_task_result..MyResult.__repr__s1$w'))r r)r(r)r*r+rrr,rLrMs@r MyResultrs $ * *r rc># T"5$7frr )rsr rARunnerTests.test_no_repr_is_call_on_the_task_result..coros: s r)rrr[rZr)rrrrrs @r 'test_no_repr_is_call_on_the_task_result3RunnerTests.test_no_repr_is_call_on_the_task_resultsV * * ^^ ZZ'F F--. s A## A1r N)r(r)r*r+rrrr$r'r,r/r2r;rNr\rgrlrvr~rrr,r r r rrsX<;3 *"   * *#&E$$(# -$#"#" /r r__main__)rrrIrZr{rraunittesttest.test_asynciorrr unittest.mockrr rAbstractEventLoopPolicyrTestCaser.rOrr(rVr r r rs 1(00(x  DP