+ NV-jRR.t^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RIt^RI t ^RI H t ^RI H t H t ^RIHtRtRtRtR t]P(!4tR tR t!R R ]4t!RR4tRt!RR]4tR!RltRt!RR]4t !RR]!4t"!RR]!4t#]#t$!RR]#4t%!RR]!4t&!RR]&4t'!R R]"4t(R#)"Pool ThreadPoolN)util) get_context TimeoutError)waitINITRUNCLOSE TERMINATEc&\\V!4#N)listmapargss&b/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/pool.pymapstarr/s T c^\\P!V^,V^,44#))r itertoolsstarmaprs&r starmapstarr2s"  !!$q'473 44rc,a]tRt^9toRtRtRtVtR#)RemoteTracebackcWnR#r tb)selfrs&&r__init__RemoteTraceback.__init__:srcVP#r rrs&r__str__RemoteTraceback.__str__<s wwrrN)__name__ __module__ __qualname____firstlineno__r r$__static_attributes____classdictcell__ __classdict__s@rrr9srrc,a]tRt^?toRtRtRtVtR#)ExceptionWithTracebackc\P!\V4W4pRPV4pWnRV,VnR#)z """ %s"""N) tracebackformat_exceptiontypejoinexcr)rr6rs&&&rr ExceptionWithTraceback.__init__@s6  ' 'S 3 ; WWR[ 2%rc>\VPVP33#r ) rebuild_excr6rr#s&r __reduce__!ExceptionWithTraceback.__reduce__EsTXXtww///rr6rN)r&r'r(r)r r:r*r+r,s@rr/r/?s& 00rr/c&\V4VnV#r )r __cause__r<s&&rr9r9Hs#B'CM JrcBaa]tRt^PtoRtV3RltRtRtRtVt V;t #)MaybeEncodingErrorzRWraps possible unpickleable errors, so they can be safely sent through the socket.c<\V4Vn\V4Vn\\V`VPVP4R#r )reprr6valuesuperr@r )rr6rC __class__s&&&rr MaybeEncodingError.__init__Ts39%[   $04::Frc@RVP: RVP: R2#)zError sending result: 'z '. Reason: '')rCr6r#s&rr$MaybeEncodingError.__str__Ys=AZZ=AXXG Grc@RVPP: RV: R2#))rEr&r#s&r__repr__MaybeEncodingError.__repr__]s!^^44d;;r)r6rC) r&r'r(r)__doc__r r$rMr*r+ __classcell__rEr-s@@rr@r@Ps 'G G<QZF  ,(F1I6G JJI  %)* + +  ,sB9D," E- F,'EE F%,FF G/)P@TPTPTPTPBTP,TPTPDTPFTPTPTPTPHYpP3R7Tn%RTPJn&\NTPJnTPJPQ4\:P<!\>PRTPTPTTPFTPTP3R7Tn+RTPVn&\NTPVnTPVPQ4\:P<!\>PXTPFTPZTP3R7Tn.RTP\n&\NTP\nTP\PQ4\^P`!YPbTPTPDTPFTPTPTPJTPVTP\TP3 ^R7Tn2\NTnR# \0dYTPF#pTP2eKTP54K% TPFpTP74K hi;i)rNz&Number of processes must be at least 1z/maxtasksperchild must be a positive int or Nonezinitializer must be a callabletargetrT)r exitpriority)3_poolr_stater_ctx _setup_queuesqueue SimpleQueue _taskqueue_change_notifierrw_cache_maxtasksperchild _initializer _initargsosprocess_cpu_count ValueErrorrTrUcallable TypeError _processes_repopulate_poolr`exitcode terminater5_get_sentinels threadingThreadr_handle_workersr_inqueue _outqueue_wrap_exception_worker_handlerdaemonr start _handle_tasks _quick_put _task_handler_handle_results _quick_get_result_handlerrFinalize_terminate_pool _terminate)r processesrerfmaxtasksperchildcontextp sentinelss&&&&&& rr Pool.__init__sO  ,,{}  ++-!% 5 5 7 $*?*?@ !1'!  ,,.33!I q=EF F  '.448HA8M !RSS  "8K+@+@<= =#   ! ! #'') (//''++t 4<<//4::t}}dnn##T^^T5K5K&& 3H3HJ '+#&)# ""$'--%%//4??DNN**dkk+ %)!$'!   "(//''..$//4;;? '+#&)# ""$-- &&//4==$..$**'')=)=t?Q?Q&& 5  ] ZZ::%KKM ZZ   s*P %Q-49Q-cVPV8XdBV!RV: 2\VR7\VRR4eVPP R4R#R#R#)z&unclosed running multiprocessing pool )sourcerN)rResourceWarninggetattrrrX)r_warnr s&&&r__del__ Pool.__del__ sT ;;#  :4(C!$ 0t/6B%%))$/C rc VPpRVP RVP RVP R\ VP 4 R2 #)rK.z state=z pool_size=rL)rEr'r(rlenr)rclss& rrM Pool.__repr__sQnnCNN#1S%5%5$67 & _-Q0 1rcjVPP.pVPP.p.VOVO#r )rr\r)rtask_queue_sentinelsself_notifier_sentinelss& rrPool._get_sentinelss< $ 6 67#'#8#8#@#@"A@%@(?@@rclVUu.uF#p\VR4'gKVPNK% up#uupi)sentinel)rZr)workersrrs& r_get_worker_sentinelsPool._get_worker_sentinelss<8%+"6:6 8 88s11c Rp\\\V444FLpW,pVPfK\P !RV,4VP 4RpWKN V#)zCleanup after any worker processes which have exited due to reaching their specified lifetime. Returns True if any workers were cleaned up. Fcleaning up worker %dT)reversedrangerrrr_r5)poolcleanedrlrrs& r_join_exited_workersPool._join_exited_workers!s^ %D *+AWF* 2Q67 G,rc VPVPVPVPVPVP VP VPVPVPVP4 #r ) _repopulate_pool_staticrrrrrrrrrrr#s&rrPool._repopulate_pool1s_++DIIt||,0OO,0JJ ,0NNDbI I I Js*A$A AA A AAc VP4V^8XdO\V4pVPPVP VP W4VP 34V#V^8d\RPV44h\PWV4p\V4pVPPVP VP \V4VP 34RV4#)z@ Equivalent of `map()` -- can be MUCH slower than `Pool.map()`. zChunksize must be 1+, not {0:n}c34"TFqFq"xK K R#5ir rt.0chunkr}s& r Pool.imap..?fUDDf) r IMapIteratorrrXr_job _set_lengthrrWr _get_tasksrrrmrrro task_batchess&&&& rimap Pool.imaps  >!$'F OO  11&++tN&&  M1} 5<<!#$$ ??49EL!$'F OO  11&++292>@&&  @f? ?rc VP4V^8XdO\V4pVPPVP VP W4VP 34V#V^8d\RPV44h\PWV4p\V4pVPPVP VP \V4VP 34RV4#)z< Like `imap()` method but ordering of results is arbitrary. zChunksize must be 1+, not {0!r}c34"TFqFq"xK K R#5ir rtrs& rr&Pool.imap_unordered..r r ) rIMapUnorderedIteratorrrXrr r rrWrrrrs&&&& rimap_unorderedPool.imap_unordereds  >*40F OO  11&++tN&&  M1} 5<@&&  @f? ?rc VP4\WV4pVPPVP^WV3.R34V#)z+ Asynchronous version of `apply()` method. N)r ApplyResultrrXr )rrmrrnrrros&&&&&& rrPool.apply_asyncsH T^< v{{At4@A4HI rc 2VPW\W4V4#)z) Asynchronous version of `map()` method. )rrrs&&&&&&r map_asyncPool.map_asyncs tw  rc VP4\VR4'g \V4pVfC\\ V4\ VP 4^,4wrGV'd V^, p\ V4^8Xd^p\ PWV4p\W\ V4VVR7p VPPVPV PVV4R34V #)zI Helper function to implement map, starmap and their async counterparts. __len__Nr) rrZrdivmodrrrr MapResultrrXrr ) rrmrmapperrrrextrarros &&&&&&& rrPool._map_asyncs x++H~H  %c(mS_q5HI IQ x=A ItyA 4CM8*8: --fkk.4.:<    rcn\WR7VP4'gVP4K(R#))timeoutN)remptyrY)rchange_notifierr(s&&&r_wait_for_updatesPool._wait_for_updatess* Y(!''))    !*rc `\P!4pVP\8XgV'dUVP\8wd@VP W4WVVWV W4 .VP V4OV OpVPVV4KqVPR4\P!R4R#)Nzworker handler exiting) rcurrent_threadrr r rrr+rXrr_)rcache taskqueuerrrrrcrdrerfrrhrr*threadcurrent_sentinelss&&&&&&&&&&&&&&& rrPool._handle_workerss ))+mms"u)1K   sYg'h/ A!O#";";D"A NI N   ! !"3_ E d +,rc\P!4p\VPR4FwrgRpVF9pVP\ 8wd\ P!R4MUV!V4K; V'd9\ P!R4V'd V^,MR p V!V ^,4R;p;rjKR;p;rjM \ P!R4\ P!R4VPR4\ P!R4VF p V!R4K \ P!R 4R# \dJp TR,wrYJ,PT RT 34Rp ? EKD \d Rp ? EKWi;iRp ? ii;i R;p;rji;i \d\ P!R4Li;i) Nz'task handler found thread._state != RUN:NNFzdoing set_length()ztask handler got sentinelz/task handler sending sentinel to result handlerz(task handler sending sentinel to workersz/task handler got OSError when sending sentinelsztask handler exitingr) rr.iterrYrr rr_r`_setKeyErrorrXr^) r0rXrdrr/r1taskseq set_lengthrjrprkidxrs &&&&& rrPool._handle_taskss))+#' t#< GD ,#D}}+ #LM!D $" #78)-d1g2"37+(,++w'+++w1$=4 JJ2 3 J JJH I LL  JJA BD  )*=%!#'8!!JOOC%<<'! ! !(,++w J JJH I Jsx2F'E/ F;FFAF# F FE:3F: F FF F FFFF #!GGch\P!4pV!4pTP \8wd4TP \8XgQR4h\P !R4M?Tf\P !R4M$TwrVpY%,PYg4R;p;rWKT'd^TP \8wdIT!4pTf\P !R4KATwrVpY%,PYg4R;p;rWKe\TR4'dT\P !R4\^ 4F,pTPP4'gM T!4K. \P !R \T4TP 4R# \\3d\P !R4R#i;i \dEL:i;i \\3d\P !R4R#i;i \dELi;i \\3dLi;i) z.result handler got EOFError/OSError -- exitingNzThread not in TERMINATEz,result handler found thread._state=TERMINATEzresult handler got sentinelz&result handler ignoring extra sentinelr\z"ensuring that outqueue is not fullz7result handler exiting: len(cache)=%s, thread._state=%s)rr.r^r]rr_rr r r7r8rZrr\pollr)rdrYr/r1rjrkrlobjs&&& rrPool._handle_results=s))+ u }}#}} 1L3LL1 IJ| 89KCC  ' $ #D #3 2 u | CDKCC  ' $ #D #3 8Y ' ' JJ; < rA#++0022E# L%j&-- )eX&  KL    X&  KL   X&  s_FG G-H 4/H$ H'GG GG'HH HHH10H1c#"\V4p\\P!W44pV'gR#W3xK15ir>N)r6tuplerislice)rmitsizers&&& rrPool._get_tasksys3 "Xi&&r01A)Os=?c\R4h)z:pool objects cannot be passed between processes or pickled)NotImplementedErrorr#s&rr:Pool.__reduce__s!J rc\P!R4VP\8Xd>\Vn\VP nVP PR4R#R#)z closing poolN)rr_rr r rrrXr#s&rr[ Pool.closesH >" ;;# DK*/D '  ! ! % %d + rch\P!R4\VnVP 4R#)zterminating poolN)rr_r rrr#s&rrPool.terminates  %&  rc\P!R4VP\8Xd \ R4hVP\ \ 39d \ R4hVPP4VPP4VPP4VPFpVP4K R#)z joining poolzPool is still runningzIn unknown stateN) rr_rr rr r rr5rrr)rrs& rr5 Pool.joins >" ;;# 45 5 [[ 2 2/0 0 !!# ! !!#A FFHrc:\P!R4VPP4VP 4'dUVP P 4'd3VP P4\P!^4KhR#R#)z7removing tasks from inqueue until task handler finishedN) rr__rlockacquireis_aliver\r?rtimesleep)rc task_handlerrGs&&&r_help_stuff_finishPool._help_stuff_finishsf LM ##%%'//*>*>*@*@ OO " JJqM+A%rc \P!R4\VnVP R4\Vn\P!R4VP W'\ V44VP4'g\ V 4^8wd \R4h\VnVP R4VP R4\P!R4\P!4VJdVP4V'dY\V^,R4'd@\P!R4VF#p V PeKV P4K% \P!R4\P!4VJdVP4\P!R4\P!4VJdVP4V'd\V^,R4'dq\P!R 4VFRp V P4'gK\P!R V P,4V P4KT R#R#R#) zfinalizing poolNz&helping task handler/workers to finishz/Cannot have cache with result_handler not alivezjoining worker handlerrzterminating workerszjoining task handlerzjoining result handlerzjoining pool workersr)rr_r rrXrYrrUrVrr.r5rZrrpid) rr0rcrdrr*worker_handlerrXresult_handlerr/rs &&&&&&&&&& rrPool._terminate_pools $% !*D!'  ;< wc$i@''))E a AC C!*D! T +,  # # %^ ;    ! GDG[11 JJ, -::%KKM )*  # # %\ 9     +,  # # %^ ;    ! GDG[11 JJ- .::<<JJ6>?FFH 24rc&VP4V#r )rr#s&r __enter__Pool.__enter__s  rc&VP4R#r )r)rexc_typeexc_valexc_tbs&&&&r__exit__ Pool.__exit__s  r)rrrrrrrrrrrrrrrrrrrt)NNrtNNr )NNN)r>)0r&r'r(r)rOr staticmethodrr warningswarnr rrMrrrrrrrrrrrrrrrrrrr+ classmethodrrrrr:r[rr5rYrrargr*r+r,s@rrrsO**Of%MMs01 A 88  B''$ 9 96 1 "8IM9 J@:@8&(b4:"" --(++++Z9)9)v , 33jrcpa]tRtRtoRtRtRtR RltR RltRt ] !] P4t R tVtR#) ricWn\P!4Vn\ \ 4VnVPVnW nW0n WPVP &R#r ) rrEvent_eventnext job_counterr r _callback_error_callback)rrrrs&&&&rr ApplyResult.__init__sG oo' % kk !-!% DIIrc6VPP4#r )rpis_setr#s&rreadyApplyResult.readys{{!!##rczVP4'g\RPV44hVP#)z{0!r} not ready)rxrrW_successr#s&r successfulApplyResult.successfuls.zz||.55d;< <}}rNc<VPPV4R#r )rprrr(s&&rrApplyResult.waits !rcVPV4VP4'g\hVP'd VP#VPhr )rrxrr{_valuers&&rrYApplyResult.gets< 'zz||  ===;; ++ rcVwVnVnVP'd.VP'dVPVP4VP'd.VP'gVPVP4VPP 4VP VPRVnR#r ) r{rrsrtrpsetrr rrrlr@s&&&rr7ApplyResult._sets|%(" t{ >>>dmmm NN4;; '       -  KK " r)rrsrtrpr rr{rr )r&r'r(r)r rxr|rrYr7rltypes GenericAlias__class_getitem__r*r+r,s@rrrs6&$ "$E$6$67rrc,a]tRtRtoRtRtRtVtR#)r#ic6\PWVVR7RVnR.V,VnW nV^8:d;^VnVP P4VPVPR#W2,\W2,4,VnR#)r!TN) rr r{r _chunksize _number_leftrprrr bool)rrrlengthrrs&&&&&&rr MapResult.__init__szT,:  < fvo # > !D  KKOO  DII& & 1D9K4L LD rcV;P^,unVwr4V'dVP'dW@PWP,V^,VP,%VP^8XdhVP'dVP VP4VP VP VPP4RVn R#R#V'g VP'dRVnW@nVP^8XdhVP'dVPVP4VP VP VPP4RVn R#R#)r>NF) rr{rrrsrr rprrrt)rrlsuccess_resultsuccessros&&& rr7MapResult._set)s Q( t}}}CIKK//)1Q3*? @  A%>>>NN4;;/KK * !! &t}}} % $   A%'''((5KK * !! &r)rrrr{rN)r&r'r(r)r r7r*r+r,s@rr#r#s M""rr#cFa]tRtRtoRtRtR Rlt]tRtRt Rt Vt R#) r iEcFWn\P!\P!44Vn\ \ 4VnVPVn\P!4Vn ^Vn RVn /VnWPVP&R#)rN)rr ConditionLock_condrqrrr r collectionsdeque_items_index_length _unsorted)rrs&&rr IMapIterator.__init__Gsl (()9: % kk !'')   !% DIIrcV#r rtr#s&r__iter__IMapIterator.__iter__Rs rNcVP;_uu_4VPP4pRRR4Xwr4T'dT#Th \dTPTP 8XdRTn\RhTPPT4TPP4pL \d2TPTP 8XdRTn\Rh\Rhi;ii;i +'giL;ir ) rrpopleft IndexErrorrrr StopIterationrr)rr(r}rrCs&& rrqIMapIterator.nextUs ZZZ 1{{**,  L ! 1;;$,,.!%DJ'T1 (1;;..0D!1{{dll2%) +5&D0 1 1Zs5C8A  AC5B53C85r)dummyr)rrrnrs&*, rrThreadPool.Processs"%%%rNc2\PWW#4R#r )rr )rrrerfs&&&&rr ThreadPool.__init__s d{=rc\P!4Vn\P!4VnVPPVnVPP VnR#r )rrrrrXrrYrr#s&rrThreadPool._setup_queuessD))+ **,--++..,,rc0VPP.#r )rr\r#s&rrThreadPool._get_sentinelss%%--..rc.#r rt)rs&rr ThreadPool._get_worker_sentinelss rcVPRR7K \PdMi;i\T4FpTP R4K R#)TF)blockN)rYrEmptyrrX)rcrXrGrls&&& rrYThreadPool._help_stuff_finishsH  % ({{   tA KK s //c2\P!V4R#r )rVrW)rrr*r(s&&&&rr+ThreadPool._wait_for_updatess 7r)rrrr)NNrt)r&r'r(r)rrirr rrrrYr+r*r+r,s@rrrs]O&&>- /r)NrtNF))__all__rrrrrrVr2rrjr1rrr connectionrrr r r countrrrrr`rr/r9r@rrradictrwobjectrr AsyncResultr#r rrrtrrrs <     '    oo 5i 00<<"+