fh, dZddlZddlZddlmZddlmZddlmZddlmZddd ej ej gej fd ej e d ejd ejejej eejej effd ZdS))staggered_raceN)events) exceptions)locks)tasks)loopcoro_fnsdelayr returnc P K ptjt| dd g g dtjt jddf  fd  d} | d}|t kr@tj d{V\}}t|} |t k@ f D]}|S# D]}|wxYw)Nprevious_failedr cK|ctjtj5t j| d{Vdddn #1swxYwY t \}}n#t$rYdSwxYwtj }  |} | d |d{V}||tD]\}}||kr| dS#tt f$rt"$r$}| |<|Yd}~dSd}~wwxYw)N) contextlibsuppressexceptions_mod TimeoutErrorrwait_forwaitnext StopIterationrEvent create_taskappend enumeratecancel SystemExitKeyboardInterrupt BaseExceptionset)r this_indexcoro_fn this_failed next_taskresultiter enum_coro_fnsrr run_one_coro running_tasks winner_index winner_results 8/opt/alt/python311/lib64/python3.11/asyncio/staggered.pyr*z$staggered_race..run_one_coroRs  &$^%@AA D D n_%9%9%;%;UCCCCCCCCC  D D D D D D D D D D D D D D D "&}"5"5 J    FF kmm $$\\+%>%>?? Y''' $ "799______F&L"M"-00  1 ??HHJJJ  %-.       %&Jz " OO          s;.AA"%A"*A== B  B *D//E. E))E.r)rget_running_looprtypingOptionalrrrrlenrrdone cancelled exceptionr)r r r first_task done_countr3_dr'r)rr*r+r,r-s `` @@@@@@r.rrs1f  ,6*,,Dh''MMLJM.#_U[9.>B.............`!!,,t"4"455J$$$ C ....!J}55555555GD!TJ , C ....lJ6  A HHJJJJ   A HHJJJJ s AD D%)__all__rr0rrrrrIterableCallable Awaitabler1floatAbstractEventLoopTupleAnyintList Exceptionrr.rHsL  *******. GGG/&/"f6F2F"GHGu%G& G  \ J OC K *+, GGGGGGrG