+ NV-jD^RIt^RIt^RIt^RIt^RIt^RIt^RIHt^RIH t .R(Ot ^t ^t ^ t ^t^t^tRtRtRsR sR tR tR tR tRtRtR)RltRtRt]!4t]P>R8Xd^lt M9]P>PCR*4'd^ht M]PDR8XdRM^\t Rt#Rt$Rt%]PL!4t']PP!4t)Rt*Rt+/t,]PP!4t-!RR].4t/R)Rlt0Rt1R s2]]]0] Pf] Ph3Rlt5]Pl!]54!RR].4t7!RR]Pp4t9]Pt!R 4t;R"t=R#t>R$t?R%t@R&tAR'tBR# ]<dR!t;Li;i)+N)_args_from_interpreter_flags)processFinalizeForkAwareThreadLockForkAwareLocal multiprocessz+[%(levelname)s/%(processName)s] %(message)sFc`\'d"\P!\V.VO5R^/R#R# stacklevelN)_loggerlogSUBDEBUGmsgargss&*b/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/multiprocess/util.py sub_debugr-s$w Hc7D7Q7c`\'d"\P!\V.VO5R^/R#R#r )r r DEBUGrs&*rdebugr1s$w E344!4rc`\'d"\P!\V.VO5R^/R#R#r )r r INFOrs&*rinfor5s$w D#333rc`\'d"\P!\V.VO5R^/R#R#r )r r WARNINGrs&*rwarnr9s$w GS646A6rc`\'d"\P!\V.VO5R^/R#R#r )r r SUBWARNINGrs&*r sub_warningr =s$w J9d9q9rc^RIpVP;_uu_4\'gVP\4s^\n\ \R4'd6\P!\4\P!\4ML\PP\R/34\PP\R/34RRR4\# +'gi\#;i)z% Returns logger used by multiprocess N unregister)logging_lockr getLogger LOGGER_NAME propagatehasattratexitr"_exit_functionregister _exithandlersremoveappend)r$s r get_loggerr0As  w'' 4G !G v|,,!!.1/$$++^R,DE$$++^R,DE  N  Ns CC++ D c^RIp\4pVP\4pVP 4pVP V4VP V4V'dVPV4Rs\#)z: Turn on logging and add a handler which prints to stderr NT) r$r0 FormatterDEFAULT_LOGGING_FORMAT StreamHandler setFormatter addHandlersetLevel_log_to_stderrr )levelr$logger formatterhandlers& r log_to_stderrr=Xsb  \F!!"89I##%G # g N Nrc(\PR9#)linux)r?android)sysplatformr#rr#_platform_supports_abstract_socketsrCms <</ //rcV'gR#\V\4'd V^,^8H#\V\4'd V^,R8H#\RV: R24h)Fzaddress type of z unrecognized) isinstancebytesstr TypeError)addresss&ris_abstract_socket_namespacerKqsT '5!!qzQ GS ! !qzT!! &wk? @@rr?ntcjV!V4\P!4pVeRVPR&R#R#)Ntempdir)rcurrent_process_config)rmtreerNrOs&& r_remove_temp_dirrRs4 7O--/O"-1 *#rcj\PR8XdR#VP4p\V4^,^,pV\8dV#.ROpVP V4p\RT4\T4^,^,\8gQhT# \ d\RY4Tu#i;i)zGet a temporary directory where socket files will be created. To prevent additional imports, pass a pre-imported 'tempfile' module. rLNzProcess-wide temporary directory %s will not be usable for creating socket files and no usable system-wide temporary directory was found in %sz-Ignoring user-defined temporary directory: %s)z/tmpz/var/tmpz/usr/tmp)osname gettempdirlen _SUN_PATH_MAX_get_default_tempdirFileNotFoundErrorr)tempfile base_tempdir sun_path_lendirlistbase_system_tempdirs& r_get_base_temp_dirr`s  ww$&&(L|$r)B.Lm#/G &;;GD 8,G " #b (2 - == =   )*6 A sBB21B2cP\P!4PPR4pVft^RIp^RIp\ V4pVPRVR7p\RV4\R\VPV3RR7V\P!4PR&V#)rNNzpymp-)prefixdirzcreated temp directory %s)r exitpriorityi) rrOrPgetshutilr[r`mkdtemprrrRrQ)rNrfr[r\s r get_temp_dirrhs%%'//33I>G)(3 ""'|"D ('2 'v}}g.F" $7>!)))4 Nrc\\P44pVP4VFwwrr4V!V4K R# \dp\ RT4Rp?K4Rp?ii;i)z after forker raised exception %sN)list_afterfork_registryitemssort Exceptionr)rlindexidentfuncobjes r_run_after_forkersrts] $**, -E JJL%*!t 8 I&+ 8 3Q 7 7 8sA A) A$$A)cJV\\\4\V4V3&R#N)rknext_afterfork_counterid)rrrqs&&rregister_after_forkrzsEH012c7DABrcfa]tRt^toRtR RltR]]]P3Rlt Rt Rt Rt RtVtR#) rz9 Class which supports object finalization using weakrefs NcVe;\V\4'g%\RPV\ V444hVe\ P !W4VnMVf \R4hW n W0n T;'g/Vn V\\43Vn\P !4VnV\$VP&R#)Nz3Exitpriority ({0!r}) must be None or int, not {1!s}z+Without object, exitpriority cannot be None)rFintrIformattypeweakrefref_weakref ValueError _callback_args_kwargsrw_finalizer_counter_keyrTgetpid_pid_finalizer_registry)selfrrcallbackrkwargsrds&&&&&&r__init__Finalize.__init__s  $jc.J.JELL $|"467 7 ?#KK2DM  !JK K! || !4(:#;< IIK )-DII&rc zW PVPV!48wd V!R4RpMOV!RVPVPVP4VP!VP/VPBpR;Vn;Vn;Vn;VnVnV# \ d T!R4R#i;i)zA Run the callback unless it has already been called or cancelled z+finalizer ignored because different processNz/finalizer calling %s with args %s and kwargs %szfinalizer no longer registered)rrrrrrKeyError)rwrrrrress&&&&& r__call__Finalize.__call__s #II.yyFH$GHK..$**dllDnndjjADLLA7; ) rAttributeErrorrI __class__rgetattrrrrHrr)rrrxs& r__repr__Finalize.__repr__>s --/C ;&)@)@@ @ '' DNNC E ::: S_, ,A <<< s4<<00 0A 99Q< # "S1%66 6A3w * C sD""D98D9)rrrrrr)r#NN)r __module__ __qualname____firstlineno____doc__rrrrTrrrrr__static_attributes____classdictcell__ __classdict__s@rrrs;.&&9$RYY 0 <0 rca\fR#SfRpMV3Rlp\\4Uu.uFq!!V4'gKVNK ppVPRR7VF2p\PV4pVfK\ RV4V!4K4 Sf\P4R#R#uupi \ d^RIpTP4Kyi;i)z Run all finalizers whose exit priority is not None and at least minpriority Finalizers with highest priority are called first; finalizers with the same priority will be called in reverse order of creation. NcV^,RJ#rNr#)ps&r!_run_finalizers..as qt4'rcB<V^,RJ;'d V^,S8#rr#)r minprioritys&rrrcs"qt4'??AaDK,??rT)reversez calling %s) rrjrmrerrn traceback print_excclear)rfkeykeys finalizerrsf r_run_finalizersrSs"  ' ? 34 ?4C#CC4D ?IIdI'++C0  lI . & !!# @ & ##% &sB-B-B22CCc.\;'g \RJ#)z. Returns true if the process is shutting down N)_exitingr#rr is_exitingrs  ' 'x4''rc\'gRsV!R4V!R4V!^4V!4eV!4FDpVP'gKV!RVP4VPP 4KF V!4F&pV!RVP4VP 4K( V!R4V!4R#R#)Tzprocess shutting downz2running all "atexit" finalizers with priority >= 0Nz!calling terminate() for daemon %szcalling join() for process %sz)running the remaining "atexit" finalizers)rdaemonrU_popen terminatejoin)rrractive_childrenrOrs&&&&& rr+r+s 8 $% BC   (%&888.ss||/A/A/CrN)rzrs&rrForkAwareLocal.__init__s D"CDrc\V4R3#)Nr#)rrs&r __reduce__ForkAwareLocal.__reduce__sDz2~rr#N)rrrrrrrrrs@rrrsEr SC_OPEN_MAXc.\V4R\.,pVP4VR,\8XgQR4h\\ V4^, 4F4p\ P !W,^,W^,,4K6 R#)z fd too largeN)rjMAXFDrmrangerWrT closerange)fdsis& rclose_all_fds_exceptrse s)r5k !CHHJ r7e +^+  3s8a<  cfQhaC)!rc\PfR#\PP4\ P !\ P\ P4p\ VRRR7\nR# \\3dLai;i \ P!T4h;i \\3dR#i;i)Nzutf-8F)encodingclosefd) rAstdincloseOSErrorrrTopendevnullO_RDONLY)fds r _close_stdinrs yy   WWRZZ - R'5ACI Z      HHRL  Z    s4B3B5)BBBB22B55C  C c\PP4\P P4R# \\3dL4i;i \\3dR#i;irv)rAstdoutflushrrstderrr#rr_flush_std_streamsrs]     J '    J '   s"AAAAA-,A-c^RIp\\\\V444p\ P !4wrEVPW.RVRRRRRRRRWERRRRRRRR4\ P!V4\ P!V4# \ P!T4\ P!T4i;i)rNTFr) _posixsubprocesstuplesortedmapr}rTpipe fork_execr)pathrpassfdsr errpipe_read errpipe_writes&&& rspawnv_passfdsr sF3sG,-.G"$'')L )) &$t BBL 5"dD$D:    s $B.B>cDVFp\P!V4K R#)z/Close each file descriptor given as an argumentN)rTr)rrs* r close_fdsr s  rc^RIHp\P!4^RIHpVP P4^RIHpVPP4\4VP4VP4R#)zGCleanup multiprocessing resources when multiprocessing tests completed.)support) forkserver)resource_trackerN) testr r_cleanuprr _forkserver_stopr_resource_trackerr gc_collect reap_children)r rrs r_cleanup_testsrsc (  ".&&,,.  r)rrrr rr0r=rhrzrrrrrrrrv)openbsdfreebsd)CrT itertoolsrArr*r subprocessrr__all__NOTSETrrrrrr'r3r r8rrrrr r0r=rCrKabstract_sockets_supportedrBrX startswithrUrRr`rhWeakValueDictionaryrkcountrxrtrzrrobjectrrrrrrOr+r,rlocalrsysconfrrnrrrr r rr#rrr&s   3        F 8547:.*0AAB<<7M\\344MGGtODM26p &113__&8I__&SvSl&$X( E?#*#:#:#*#:#:(T *&*"Y__ JJ} %E* .    M EsE>> F  F