+ :1jSRt^RIHt^RIt^RIt^RIt^RIt^RIHt^RI H t H t H t H t ^RIHt^RIHt^RIHtHt^RIHtHt^R IHtHt^R IHtHtHtHtHt^R I H!t!H"t"H#t#H$t$^R I%H&t&^R I'H't'^RI(H)t)^RI*H+t+])'d^RI,H-t-H.t.H/t/H0t0^RIH1t1^RI(H2t2^RI3H4t4^RI5H6t6^RI7H8t8^RI9H:t:^RI;HH?t?^RI@HAtA]!]B4tC]D!]PR4;'d]PP4tG!RR]4tH]6!]PPR44'd ]H!R4tKM]!R4tKRIR R!lltL!R"R#4tM!R$R%]M4tN]N!4tO!R&R']4tP]]:!R(R)4RJR*R+ll44tQ]]:!R(R)4RKR,R-ll44tR]]:!R(R)4RLR.R/ll44tS]]PP]PP3R0R1ll4tU]R2R3l4tV]R4R5l4tW]RLR6R7ll4tX]RR8RR3R9R:lltYR;R/R<R=lltZ!R>R?] 4t[!R@RA] 4t\] t RBRClt]!RDRE]M4t^RFRGlt_]BRH8Xd ]_!4R#R#)MzCommon I/O utilities.) annotationsN) defaultdict)ExecutorFutureThreadPoolExecutor as_completed)contextmanager)Enum)EPIPE ESHUTDOWN)partialwraps)BytesIOStringIO)CRITICALWARN Formatter StreamHandler getLogger)dirnameisdirisfilejoin)Lock)time) TYPE_CHECKING) memoizemethod)Callable GeneratorIterableIterator) LogRecord)Any) NullHandler)boolify)json) deprecated)encode_environmenton_win)NULL)expandisattycHa]tRt^+tRtRRV3RllltRV3RlltRtV;t#)DeltaSecondsFormatteraW Logging formatter with additional attributes for run time logging. Attributes: `delta_secs`: Elapsed seconds since last log/format call (or creation of logger). `relative_created_secs`: Like `relativeCreated`, time relative to the initialization of the `logging` module but conveniently scaled to seconds as a `float` value. c$V^8dQhRRRRRR/#)fmt str | NonedatefmtreturnNone)formats"/lib/python3.14/site-packages/conda/common/io.py __annotate__"DeltaSecondsFormatter.__annotate__7s( 3 3  3 3  3c F<\4Vn\SV` WR7R#)zInitialize the formatter with optional format strings. :param fmt: Log message format string. :param datefmt: Date format string. )r0r2N)r prev_timesuper__init__)selfr0r2 __class__s&&&r7r>DeltaSecondsFormatter.__init__7s S2r:c V^8dQhRRRR/#)r/recordr!r3strr5)r6s"r7r8r9Ds&&Y&3&r:c <\4pVPp\VPV4VnW#, VnVPR, Vn\ SV`V4#)i)rr<max delta_secsrelativeCreatedrelative_created_secsr=r6)r?rCnowr<r@s&& r7r6DeltaSecondsFormatter.formatDsQfNN T^^S1O'-'='='D$w~f%%r:)r<NN) __name__ __module__ __qualname____firstlineno____doc__r>r6__static_attributes__ __classcell__r@s@r7r-r-+s  3 3&&r:r-CONDA_TIMED_LOGGINGzm%(relative_created_secs) 7.2f %(delta_secs) 7.2f %(levelname)s %(name)s:%(funcName)s(%(lineno)d): %(message)sz<%(levelname)s %(name)s:%(funcName)s(%(lineno)d): %(message)sc$V^8dQhRRRRRR/#)r/iterable Iterable[Any]indentintr3rDr5)r6s"r7r8r8Xs&JJ}JcJ#Jr:c:aRPV3RlV44#)zFormat an iterable as a dashed list with optional indentation. :param iterable: Items to format. :param indent: Number of spaces for indentation. :returns: Formatted string with each item on a new line prefixed by ``- ``. c3r<"TF,pRRS,,R,\V4,xK. R#5i)  z- N)rD).0xrYs& r7 dashlist.._s+I14#,&-A66s47)r)rWrYs&fr7dashlistrdXs 77II IIr:c&]tRt^btRtRRltRtR#)ContextDecoratorzqBase class for a context manager class (implementing __enter__() and __exit__()) that also makes it a decorator. c V^8dQhRRRR/#r/fCallable[..., Any]r3r5)r6s"r7r8ContextDecorator.__annotate__is,1Cr:c 4aa\S4VV3Rl4pV#)cf<S;_uu_4S!V/VBuuRRR4# +'giR#;iNr5)argskwdsrir?s*,r7 decorated,ContextDecorator.__call__..decoratedjs!$'$'s 0 )r )r?rirqsff r7__call__ContextDecorator.__call__is! q (  (r:r5N)rMrNrOrPrQrsrRr5r:r7rfrfbs r:rfc2]tRt^rtRtRRltRRltRtR#)SwallowBrokenPipezcIgnore BrokenPipeError and errors related to stdout or stderr being closed by a downstream program.cV^8dQhRR/#r/r3r4r5)r6s"r7r8SwallowBrokenPipe.__annotate__us  4 r:c R#rnr5r?s&r7 __enter__SwallowBrokenPipe.__enter__us r:c(V^8dQhRRRRRRRR/#) r/exc_typetype[BaseException] | Noneexc_valBaseException | Noneexc_tbr"r3z bool | Noner5)r6s"r7r8ryxs2  , &    r:c V'dM\V\4'd5\VRR4'd VP\\ 39dR#R#R#R#R#)errnoNT) isinstanceEnvironmentErrorgetattrrr r )r?rrrs&&&&r7__exit__SwallowBrokenPipe.__exit__xsL 7$455$// %!33406 r:r5N)rMrNrOrPrQr|rrRr5r:r7rvrvrsm   r:rvc"]tRt^tRtRtRtRtR#) CaptureTargetz{Constants used for contextmanager captured. Used similarly like the constants PIPE, STDOUT for stdlib's subprocess.Popen. r5N)rMrNrOrPrQSTRINGSTDOUTrRr5r:r7rrs F Fr:rz26.9z27.3c(V^8dQhRRRRRRRR/#) r/var_mapzdict[str, str] | NonecallbackCallable[[], None] | Nonestack_callbackCallable[[bool], None] | Noner3Generator[None, None, None]r5)r6s"r7r8r8s0"""" """'""2""! ""r:c#"Vf/p\V4p/pVP4F>wrV\PP V\ 4WE&V\PV&K@ V'dV!4V'd V!R4RxVP4F5wrVV\ Jd\PVK"V\PV&K7 V'dV!4V'd V!R4R#R# TP4F5wrVT\ Jd\PTK"T\PT&K7 T'dT!4T'd T!R4ii;i5i)aTemporarily set environment variables. :param var_map: Dictionary of environment variable names to values. :param callback: Optional callback invoked when entering and exiting the context. :param stack_callback: Optional callback invoked with True when entering, False when exiting. NTF)r'itemsosenvirongetr))rrr new_var_map saved_varsnamevalues&&& r7env_varsrs$W-KJ"((* ::>>$5   4+"  J  4  %++-KD}JJt$#( 4 .  J  5 ! &++-KD}JJt$#( 4 .  J  5 ! sDA&E&)C81C8 C8 AE&E&, E&8AE# E# E##E&c ,V^8dQhRRRRRRRRRR /#) r/rrDrrrrrr3rr5)r6s"r7r8r8s:  (2  ! r:c#"W/p\WBVR7;_uu_4pVxRRR4R# +'giR#;i5i)a2Temporarily set a single environment variable. :param name: Environment variable name. :param value: Environment variable value. :param callback: Optional callback invoked when entering and exiting the context. :param stack_callback: Optional callback invoked with True when entering, False when exiting. )rrNr)rrrrdess&&&& r7env_varrs1  A !~ F F" G F F Fs>* > ; >c V^8dQhRRRR/#)r/rrr3rr5)r6s"r7r8r8s' r:c#x"\VR7;_uu_4pVxRRR4R# +'giR#;i5i)zContext manager that ensures environment variables are not modified. :param callback: Optional callback invoked when entering and exiting the context. )rNr)rrs& r7env_unmodifiedrs' 8 $ $ % $ $ $s:& : 7 :c$V^8dQhRRRRRR/#)r/stdoutzCaptureTarget | None | Anystderrr3zGenerator[Any, None, None]r5)r6s"r7r8r8s+^5^5 &^5 &^5 ^5r:c#"Rp!RR4p\P\PrTV\P8Xd8\ 4pVP Vn\W&4VnV\nMTpVe V\nV\P8Xd8\ 4pVP Vn\W'4VnV\nM4V\P8XdT;\npMTpVe V\nV!4p\PR4VxV\P8XdVP4VnMWhnV\P8XdVP4VnM#V\P8Xd RVnMWxnWEu\n\n\PR4R# T\P8XdTP4TnMYhnT\P8XdTP4TnM#T\P8Xd RTnMYxnYEu\n\n\PR4i;i5i)aCapture outputs of sys.stdout and sys.stderr. If stdout is STRING, capture sys.stdout as a string, if stdout is None, do not capture sys.stdout, leaving it untouched, otherwise redirect sys.stdout to the file-like object given by stdout. Behave correspondingly for stderr with the exception that if stderr is STDOUT, redirect sys.stderr to stdout target and set stderr attribute of yielded object to None. .. code-block:: pycon >>> from conda.common.io import captured >>> with captured() as c: ... print("hello world!") ... >>> c.stdout 'hello world!\n' Args: stdout: capture target for sys.stdout, one of STRING, None, or file-like object stderr: capture target for sys.stderr, one of STRING, STDOUT, None, or file-like object Yields: CapturedText: has attributes stdout, stderr which are either strings, None or the corresponding file-like function argument. c\VR4'dRVP9d\pM#\V\4'd\pM\ p\W4'go\VR4'd%VP R4pVPV4R#\VR4'd%VPR4pVPV4R#R#VPV4R#)modebdecodezutf-8encodeN) hasattrrbytesrrrDr old_writer)r?to_writewanteddecodedrs&& r7 write_wrappercaptured..write_wrappers 4 SDII%5F g & &FF(++x**"//'2w'8,,OOG,q!- NN8 $r:c]tRtRtRtR#)captured..CapturedTextir5NrMrNrOrPrRr5r:r7 CapturedTextrs r:rNzovertaking stderr and stdoutzstderr and stdout yielding back) sysrrrrrwriterr rlogdebuggetvalue) rrrr saved_stdout saved_stderroutfileerrfilecs && r7capturedrs@%(  "%SZZ, %%%*#MM 7     CJ %%%*#MM 7  ='' '&& W   CJAII,-5 ])) )'')AHH ])) )'')AH }++ +AHH!- CJ 34 ])) )'')AHH ])) )'')AH }++ +AHH!- CJ 34s D&J)G-B,JB,JJc V^8dQhRRRR/#)r/ args_listz list[str]r3rr5)r6s"r7r8r8?s  I "= r:c#"\PpV\nRxV\nR# T\ni;i5i)zkTemporarily replace sys.argv with the given list. :param args_list: List of arguments to use as sys.argv. N)rargv)r saved_argss& r7rr>s- JCH :sA0 A =Ac V^8dQhRRRR/#)r/ logger_namerDr3rr5)r6s"r7r8r8Ms$$$(C$r:c #"\V4pVPVPVPrCp\ 4p\ P ;_uu_4VPV4VP\^,4RRuVnVnRRR4Rx\ P ;_uu_4VPV4W#uVnVnWAnRRR4R# +'giL];i +'giR#;i \ P ;_uu_4TPT4Y#uTnTnYAnRRR4i +'gii;i;i5i)zvTemporarily disable a logger by setting its level above CRITICAL. :param logger_name: Name of the logger to disable. TFN) rleveldisabled propagater#logging_lock addHandlersetLevelr removeHandler)rlogr_lvl_dsbld_prpgt null_handlers& r7disable_loggerrLs [ !D::t}}dnn&D=L   % hl#(,e% t~ $ ]]]   | ,(, %DJ #N] ]]W]]]   | ,(, %DJ #N]]]sfAE*=C%E*D E*5&C8 E*% C5 0E*8 D  E* E'%&E E' E$ E''E*c$V^8dQhRRRRRR/#)r/rrZrr1r3rr5)r6s"r7r8r8cs&$$ $$!$r:c #^"\V4pVPVPVPVP3wr4rV\ \ P4pRVnVPV4VP\4\P;_uu_4VPV4.RRuVnVnVnVPV4VPV4RRR4Rx\P;_uu_4W4VuVnVnVnWbnRRR4R# +'giLS;i +'giR#;i \P;_uu_4Y4TuTnTnTnYbnRRR4i +'gii;i;i5i)zTemporarily set a logger to output to stderr at the given level. :param level: Logging level (e.g., :const:`logging.INFO`). :param logger_name: Name of the logger; if None, uses the root logger. rFN)rhandlersrrrrrrrr setFormatter _FORMATTERrrr)rrr_hndlrsrrrhandlers&& r7stderr_log_levelrbs# [ !D     %!G6 CJJ'GGL U $  e795%4 t}dn   e  $ ]]]7>f 4DM4:t}#N] ]]W]]]7>f 4DM4:t}#N]]]sgBF-A D2'F-0E4F- E( F-2 E =F- E  F-F*2F  F* F' "F**F-Fc 0V^8dQhRRRRRRRRR R R R /#) r/rrZrr1rbool formatterzFormatter | NonefilterszIterable[Any] | Noner3r4r5)r6s"r7r8r8sD*#*# *#*#*# *# " *#  *#r:cR\V4p\RVP4R4p\\P 4pRVnVPV4TPT;'g\4T;'gRFpVPV4K \P;_uu_4V'dVPV4VPV4WP48dVPV4W%nRRR4R# +'giR#;i)a/Attach a new `stderr` handler to the given logger and configure both. This function creates a new StreamHandler that writes to `stderr` and attaches it to the logger given by `logger_name` (which maybe `None`, in which case the root logger is used). If the logger already has a handler by the name of `stderr`, it is removed first. The given `level` is set **for the handler**, not for the logger; however, this function also sets the level of the given logger to the minimum of its current effective level and the new handler level, ensuring that the handler will receive the required log records, while minimizing the number of unnecessary log events. It also sets the loggers `propagate` property according to the `propagate` argument. The `formatter` argument can be used to set the formatter of the handler. c3J"TFqPR8XgKVxK R#5i)rN)r)r`rs& r7rb(attach_stderr_handler..sJ W1I s# #Nrr5)rnextrrrrrrrr addFilterrrrrgetEffectiveLevelr) rrrrrrold_stderr_handlernew_stderr_handlerfilter_s &&&&& r7attach_stderr_handlerrs, [ !DJ JD 'szz2&&##I$;$;<==b=$$W-!     1 2 *+ ))+ + MM% " s 5AD D& default_returnc 0V^8dQhRRRRRRRRRRR R/#) r/ timeout_secsz int | floatfuncrjror"rkwargsr3r5)r6s"r7r8r8sD)")")" )" )" )"  )"  )"r:c`a\'d V!V/VB#!RR\4oV3Rlp\P!\PV4\P !V4V!V/VBp\P !^4V# \dTu#i;i S\3dTu#i;i)aEnforce a maximum time for a callable to complete. Not yet implemented on Windows. :param timeout_secs: Maximum seconds to allow the callable to run. :param func: Callable to execute. :param args: Positional arguments to pass to the callable. :param default_return: Value to return if timeout or KeyboardInterrupt occurs. :param kwargs: Keyword arguments to pass to the callable. :returns: Return value of the callable, or ``default_return`` on timeout/interrupt. c]tRtRtRtR#)!timeout..TimeoutExceptionir5Nrr5r:r7TimeoutExceptionrs r:rc<S!4hrnr5)signumframers&&r7 interrupttimeout..interrupts "$ $r:)r(KeyboardInterrupt ExceptionsignalSIGALRMalarm)rrrrorrretrs&&$*, @r7timeoutr s$v "(( (  y  %  fnni0 \" "''C LLOJ!! "! ! ""!"34 "! ! "s#B(B BBB-,B-cN]tRtRtRtRRltRRltRRltR R R lltR t R #) DummyExecutorizISynchronous executor for debugging; executes tasks in the current thread.cV^8dQhRR/#rxr5)r6s"r7r8DummyExecutor.__annotate__s$$$$r:c 2RVn\4VnR#)FN) _shutdownr _shutdownLockr{s&r7r>DummyExecutor.__init__s!Vr:c(V^8dQhRRRRRRRR/#)r/fnrjror"rr3z Future[Any]r5)r6s"r7r8rs)  + C 3 ; r:c @VP;_uu_4VP'd \R4h\4pV!V/VBpVP V4VuuRRR4# \ dpTP T4Rp?L-Rp?ii;i +'giR#;i)z*cannot schedule new futures after shutdownN)rr RuntimeErrorr set_result BaseException set_exception)r?rrorriresultes&&*, r7submitDummyExecutor.submits    ~~~"#OPPA %T,V, V$ ! #"" #  s4(B A#B # B .B?B B  B  B c$V^8dQhRRRRRR/#)r/rrj iterablesrXr3z Iterator[Any]r5)r6s"r7r8rs("" """  "r:c' F"VFpVF pV!V4xK K R#5i)zrr#r(rRr5r:r7r r sS$ """r:r cHa]tRtRtRtRRV3RllltRV3RlltRtV;t#) ThreadLimitedThreadPoolExecutorizDThread pool executor that gracefully handles thread creation limits.c V^8dQhRRRR/#)r/ max_workersrZr3r4r5)r6s"r7r8,ThreadLimitedThreadPoolExecutor.__annotate__s&&C&&r:c &<\SV`V4R#rn)r=r>)r?r-r@s&&r7r>(ThreadLimitedThreadPoolExecutor.__init__s %r:cV^8dQhRR/#rxr5)r6s"r7r8r. s  d r:c |<\SV`4# \d \TP4^8dR#hi;i)N)r=_adjust_thread_countrlen_threads)r?r@s&r7r44ThreadLimitedThreadPoolExecutor._adjust_thread_count s@ 7/1 1 4==!A% s %;;r5) ) rMrNrOrPrQr>r4rRrSrTs@r7r+r+sN&&  r:r+cV^8dQhRR/#)r/r3rDr5)r6s"r7r8r8sr:cn\RRR4p\\PP RV44#)zReturn the path to the instrumentation record file. :returns: Expanded path from ``CONDA_INSTRUMENTATION_RECORD_FILE`` or default location. ~z.condazinstrumentation-record.csv!CONDA_INSTRUMENTATION_RECORD_FILE)rr*rrr)default_record_files r7get_instrumentation_record_filer>s5 sH.JK  :Context decorator for recording execution times to a CSV file.Nz float | None start_timezdict[str, int]total_call_numzdict[str, float]total_run_timec$V^8dQhRRRRRR/#)r/ entry_namer1 module_namer3r4r5)r6s"r7r8time_recorder.__annotate__-s(''' '  'r:c WnW nR#rn)rErF)r?rErFs&&&r7r>time_recorder.__init__-s %&r:c V^8dQhRRRR/#)r/rirjr3r4r5)r6s"r7r8rG5s))!3))r:c VPfj\VR4'dVPpMRVP,pVP'dRP VPV34pW nR#R#)NrO:.)rErrOrMrFr)r?rirEs&& r7_set_entry_nametime_recorder._set_entry_name5s_ ?? "q.))^^  1::-  XXt'7'7&DE (O #r:c V^8dQhRRRR/#rhr5)r6s"r7r8rG?s##,#1C#r:c D<VPV4\SV` V4#rn)rNr=rs)r?rir@s&&r7rstime_recorder.__call__?s! Qw""r:cV^8dQhRR/#)r/r3r@r5)r6s"r7r8rGCs=r:c \PPR4pV'd!\V4'd\ 4VnV#)CONDA_INSTRUMENTATION_ENABLED)rrrr$rrA)r?enableds& r7r|time_recorder.__enter__Cs0**..!@A ww''"fDO r:c(V^8dQhRRRRRRRR/#) r/rrrrrr"r3r4r5)r6s"r7r8rGIs299,9&9 9  9r:c VP'dVPp\4pWPP, pVPV;;,^, uu&VPV;;,V, uu&VP 4\ VPR4;_uu_4pVPV RVR R24RRR4R#R# +'giR#;i)a,rir^N) rArErrBrC _ensure_diropen record_filer)r?rrrrEend_timerun_timefhs&&&& r7rtime_recorder.__exit__Is ???JvH//1H    +q 0 +    +x 7 +    d&&,,J !3!3!8!8!:;J HH%"":."":.  r_rA__annotations__rrZrBfloatrCr>rNrsr|r classmethodrjrr]rRrSrTs@r7r@r@%s}H13K#J #%0%5NN5'25'9N$9')## 9&  33r:r@cV^8dQhRR/#rxr5)r6s"r7r8r8psTTDTr:c \4p\\4p/p\V4'gR#\ V4;_uu_4pVFDpVP 4P R4wrVW,P\V44KF RRR4\V4F3pW,p\V4p\V4pWh, p RVRVRV /W%&K5 \\P!VR^RR74R# +'giLw;i) zCPrint aggregated instrumentation data from the record file as JSON.Nr\counts total_time average_timeT) sort_keysrY separators)r\z: )r>rlistrr^stripsplitappendrqrgr5sumprintr%dumps) r_ grouped_data final_datarblinerErv all_timesrurws r7print_instrumentation_datarps13Kt$LJ +   k  bD%)ZZ\%7%7%< "J  $ + +E*,= >  \*  , Y^ !* f * L"  + $**Z4k RS!  s A C<< D __main__)r/)NNNrLrn)`rQ __future__rrrrr collectionsrconcurrent.futuresrrrr contextlibrenumr rr r functoolsr r iorrrrrrros.pathrrrr threadingrrtypingrauxlib.decoratorsrcollections.abcrrrr r!r" auxlib.logzr#auxlib.type_coercionr$common.serializer% deprecationsr&compatr'r( constantsr)pathr*rMrrrr+IS_INTERACTIVEr-rrrrdrfrvswallow_broken_piperrrrrrrrrrr r r+r>r@rr5r:r7rs_" #QQ%"$ GG00 -GG!%*#%.X.FF3::3D3D3F&I&D 2::>>/ 011& GJ FJ J   (*()D FF""""J FF$ FF)6)=)=)6)=)=^5^5B  $$*$$D""&$( *#Z)" )"Z""H""J&8( H3$H3VT: z r: