+ NV-ja0t$^RIHtR't^RIt^RIt^RIt^RIHt^RI H t ^RI H t H t Ht^RIHtHt^RIHt^RIHt^R IHt]P0R(8d ^R I HtHtM^R IHtHt]P0R)8d^R IHtHtR R lt!RR4t M_]P0R*8dE^RI!t!^RI"t"^t#R]$R&^t%R]$R&^t&R]$R&]&]#3t'R]$R&]%]#3t(R]$R&])!RRR4t*!RR4t M !RR4t ^t+R]$R&^t,]!R4t-]!R4t.]]] ,,!R4t/]],!R4t0R R!lt1R"R/R#R$llt2R%R&lt3R#)+) annotationsN)deque)Callable)AnyFinalTypeVar) current_time to_thread)BrokenWorkerInterpreter)CapacityLimiter)RunVar) TypeVarTupleUnpack)ExecutionFailedcreatec$V^8dQhRRRRRR/#)funczCallable[..., Any]argstuple[Any, ...]returnztuple[Any, bool])formats"e/Volumes/fast/ai/experiments/ui-tars-smoke/.venv/lib/python3.14/site-packages/anyio/to_interpreter.py __annotate__rs$!! !(7! !cPV!V!pVR3# \dpTR3uRp?#Rp?ii;i)FTN) BaseException)rrretvalexcs&& r _interp_callr!s8 !4[F5=  9  s % %%cJ]tRt^&t$^tR]R&RRltRRltRRltR t R #) _Workerfloat last_usedcV^8dQhRR/#rrNoner)rs"rr_Worker.__annotate__)s ) )d )rc $\4VnR#N)r _interpreterselfs&r__init___Worker.__init__)s &D rcV^8dQhRR/#r'r)rs"rrr),s & &T &rc :VPP4R#r+)r,closer-s&rdestroy_Worker.destroy,s    # # %rc$V^8dQhRRRRRR/#rrzCallable[..., T_Retval]rrrT_Retvalr)rs"rrr)/s(  ) "  rc VPP\W4wr4T'dThT# \dp\ TP 4ThRp?ii;ir+)r,callr!rr excinfo)r.rrres is_exceptionr s&&& rr: _Worker.call/sW  D$($5$5$:$:<$T! J # D-ckk:C Ds"0 AAA)r,N __name__ __module__ __qualname____firstlineno__r%__annotations__r/r4r:__static_attributes__rrrr#r#&s  5 ) &  rr#rUNBOUND FMT_UNPICKLED FMT_PICKLEDQUEUE_PICKLE_ARGSQUEUE_UNPICKLE_ARGSa_ import _interpqueues from _interpreters import NotShareableError from pickle import loads, dumps, HIGHEST_PROTOCOL QUEUE_PICKLE_ARGS = (1, 2) QUEUE_UNPICKLE_ARGS = (0, 2) item = _interpqueues.get(queue_id)[0] try: func, args = loads(item) retval = func(*args) except BaseException as exc: is_exception = True retval = exc else: is_exception = False try: _interpqueues.put(queue_id, (retval, is_exception), *QUEUE_UNPICKLE_ARGS) except NotShareableError: retval = dumps(retval, HIGHEST_PROTOCOL) _interpqueues.put(queue_id, (retval, is_exception), *QUEUE_PICKLE_ARGS) zexeccJ]tRt^dt$^tR]R&RRltRRltRRltR t R #) r#r$r%cV^8dQhRR/#r'r)rs"rrr)gs  d rc \P!4Vn\P!^.\O5!Vn\P !VPRVP /4R#)queue_idN) _interpretersr_interpreter_id _interpqueuesrJ _queue_idset___main___attrsr-s&rr/r0gsM#0#7#7#9D *11!J6IJDN  , ,$$z4>>&B rcV^8dQhRR/#r'r)rs"rrr)ns 8 8T 8rc \P!VP4\P!VP4R#r+)rSr4rTrQrRr-s&rr4r5ns(  ! !$.. 1  ! !$"6"6 7rc$V^8dQhRRRRRR/#r7r)rs"rrr)rs(  ) "   rc ^RIpVPW3VP4p\P!VP V.\ O5!\P!VP\4pV'd \V4h\P!VP 4pVR,wwrgpV\8XdVPV4pV'dVhV#)rN:NrN)pickledumpsHIGHEST_PROTOCOLrSputrTrIrQrKrR _run_funcr getrHloads) r.rrrZitemexc_infor<r=fmts &&& rr:r>rs << f.E.EFD   dnnd G5F G$))$*>*> JH-h77##DNN3C'*2w $ Sk!ll3' Jr)rRrTNr?rrrr#r#ds  5  8  rcJ]tRt^t$^tR]R&RRltRRltRRltR t R #) r#r$r%cV^8dQhRR/#r'r)rs"rrr)s O Od Orc \R4h)z,subinterpreters require at least Python 3.13) RuntimeErrorr-s&rr/r0sMN Nrc$V^8dQhRRRRRR/#r7r)rs"rrr)s( & &) &" &  &rc \hr+)NotImplementedError)r.rrs&&&rr:r>s & %rcV^8dQhRR/#r'r)rs"rrr)s  T rc R#r+rr-s&rr4r5s rrN) r@rArBrCr%rDr/r:r4rErrrr#r#s! 5 O &  rDEFAULT_CPU_COUNTr8PosArgsT_available_workers_default_interpreter_limiterc V^8dQhRRRR/#)rworkerszdeque[_Worker]rr(r)rs"rrrs>drcXVFpVP4K VP4R#r+)r4clear)rrworkers& r _stop_workersrvs! MMOrlimiterc(V^8dQhRRRRRRRR/#) rrz&Callable[[Unpack[PosArgsT]], T_Retval]rzUnpack[PosArgsT]rwzCapacityLimiter | Nonerr8r)rs"rrrs06$6$ 06$ 6$$6$ 6$rcz"Vf \4p\P4pT;_uu_4GRjxL VP4pRRR4GRjxL \P!XPVVVR7GRjxL \4pV'd^WS^,P , \"8:dM:\P!VP%4P&VR7GRjxL Ke\4VnVP)V4# \d?\ 4p\P T4\ P!\T4EL8i;iEL. \d\4pEL3i;iEL, +GRjxL 'giELD;iELL \4pT'd_YS^,P , \"8:dM;\P!TP%4P&TR7GRjxL Kf\4XnTP)T4i;i5i)a Call the given function with the given arguments in a subinterpreter. .. warning:: On Python 3.13, the :mod:`concurrent.interpreters` module was not yet available, so the code path for that Python version relies on an undocumented, private API. As such, it is recommended to not rely on this function for anything mission-critical on Python 3.13. :param func: a callable :param args: the positional arguments for the callable :param limiter: capacity limiter to use to limit the total number of subinterpreters running (if omitted, the default limiter is used) :return: the result of the call :raises BrokenWorkerInterpreter: if there's an internal error in a subinterpreter Nrw)#current_default_interpreter_limiter _idle_workersr_ LookupErrorrsetatexitregisterrvpop IndexErrorr#r run_syncr:r r%MAX_WORKER_IDLE_TIMEpopleftr4append)rrwr idle_workersrunows&$* rrrs*575$((* ww !%%'Fw $'' KK     n!_...2FF$$\%9%9%;%C%CWU U U'>F#9 5w ,' |45  YF www  V n!_...2FF$$\%9%9%;%C%CWU U U'>F#sH;DH;E"H;FE% H;FH;'F&F!F&H;AH;.F$/'H;AEH;EH;%E>:F=E>>FH;F F  F F  H;!F&$H;&H89AH8H(H88H;cV^8dQhRR/#)rrr r)rs"rrrs_rc\P4# \dG\\P !4;'g\ 4p\PT4Tu#i;i)z Return the capacity limiter used by default to limit the number of concurrently running subinterpreters. Defaults to the number of CPU cores. :return: a capacity limiter object )rpr_r}r os cpu_countrmr~rzs rr{r{sQ+//11 !",,."E"E4EF$((1s+A'"A'&A')rr{) )r)r )4__conditional_annotations__ __future__r__all__rrsys collectionsrcollections.abcrtypingrrrr r _core._exceptionsr _core._synchronizationr lowlevelr version_inforrtyping_extensionsconcurrent.interpretersrrr!r#rSrQrFrDrGrHrIrJcompiler^rmrr8rnr|rprvrr{)rs@rrsW""   $&&%63w++6w?!.  GUM5K +W5u5"/!99 0 5I:##L"5 :   #uW~&';< %o67UV6$'+6$rr