siCSrSSKrSSKrSSKrSSKrSSKJr SSKJrJ r J r J r SSK J r SSKJr SSKJrJr SSKJrJr SS KJrJr SS KJrJrJrJrJr SS KJrJ r J!r!J"r" SS K#J$r$ SS K%J%r% SSK&J'r' SSK(J)r) SSK*J+r+ SSK,J-r- SSK.J/r/ SSK0J1r1J2r2 SSK3J4r4 SSK5J6r6 \"\75r8\9"\RtS5=(a \RtRw5r<"SS\5r=\+"\R|RS55(a \="S5r@O\"S5r@S>SjrA"SS 5rB"S!S"\B5rC\C"5rD"S#S$\5rE\ S?S%j5rF\ S@S&j5rG\ SAS'j5rH\ \ER\ER4S(j5rJ\ S)5rK\/"S*S+S,S-9\ S.55rL\ S/5rM\ SAS0j5rN\SS1SS4S2jrOSS3.S4jrP"S5S6\5rQ"S7S8\ 5rR\ r S9rS"S:S;\B5rTS<rU\7S=:Xa\U"5 gg)BzCommon I/O utilities.N) defaultdict)ExecutorFutureThreadPoolExecutor as_completed)contextmanager)Enum)EPIPE ESHUTDOWN)partialwraps)BytesIOStringIO)CRITICALWARN Formatter StreamHandler getLogger)dirnameisdirisfilejoin)Lock)time) memoizemethod) NullHandler)boolify)json) deprecated)encode_environmenton_win)NULL)expandisattyc<^\rSrSrSrSU4SjjrU4SjrSrU=r$)DeltaSecondsFormatter"aW 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>>[5Ul[TU] XS9 g)N)fmtdatefmt)r prev_timesuper__init__)selfr+r, __class__s /lib/python3.13/site-packages/conda/common/io.pyr/DeltaSecondsFormatter.__init__.s S2c>[5nURn[URU5UlX#- UlURS- Ul[ TU]U5$)Ni)rr-max delta_secsrelativeCreatedrelative_created_secsr.format)r0recordnowr-r1s r2r:DeltaSecondsFormatter.format2sQfNN T^^S1O'-'='='D$w~f%%r4)r-NN) __name__ __module__ __qualname____firstlineno____doc__r/r:__static_attributes__ __classcell__r1s@r2r(r("s 3&&r4r(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:^SRU4SjU55$)Nc3R># UHnSST--S-[U5-v M g7f)  z- N)str).0xindents r2 dashlist..Gs(I14#,&-A6s$')r)iterablerPs `r2dashlistrTFs 77II IIr4c\rSrSrSrSrSrg)ContextDecoratorJzqBase class for a context manager class (implementing __enter__() and __exit__()) that also makes it a decorator. c4^^[T5UU4Sj5nU$)NcN>T T"U0UD6sSSS5 $!,(df  g=fN)argskwdsfr0s r2 decorated,ContextDecorator.__call__..decoratedRs$'$'s $)r )r0r^r_s`` r2__call__ContextDecorator.__call__Qs! q (  (r4r[N)r?r@rArBrCrarDr[r4r2rVrVJs  r4rVc \rSrSrSrSrSrg)SwallowBrokenPipeZcgrZr[r0s r2 __enter__SwallowBrokenPipe.__enter__^s r4cU(aE[U[5(a/[USS5(aUR[[ 4;aggggg)NerrnoT) isinstanceEnvironmentErrorgetattrrkr r )r0exc_typeexc_valexc_tbs r2__exit__SwallowBrokenPipe.__exit__asJ 7$455$// %!33406 r4r[N)r?r@rArBrhrrrDr[r4r2rdrdZs  r4rdc \rSrSrSrSrSrSrg) CaptureTargetnz{Constants used for contextmanager captured. Used similarly like the constants PIPE, STDOUT for stdlib's subprocess.Popen. r[N)r?r@rArBrCSTRINGSTDOUTrDr[r4r2ruruns F Fr4ruc## Uc0n[U5n0nUR5H>upV[RR U[ 5XE'U[RU'M@ U(aU"5 U(aU"S5 Sv UR5H4upVU[ La[RU M!U[RU'M6 U(aU"5 U(a U"S5 gg!UR5H4upVU[ La[RU M!U[RU'M6 U(aU"5 U(a U"S5 ff=f7f)NTF)r"itemsosenvirongetr$)var_mapcallbackstack_callback new_var_map saved_varsnamevalues r2env_varsrxs$W-KJ"((* ::>>$5   4+"  J  4  %++-KD}JJt$#( 4 .  J  5 ! &++-KD}JJt$#( 4 .  J  5 ! s A%E(!C0 A'E0A(EEc#b# X0n[XBUS9nUv SSS5 g!,(df  g=f7f)N)rrr)rrrrdess r2env_varrs) A !~ F" G F Fs/ / ,/c#Z# [US9nUv SSS5 g!,(df  g=f7f)N)rr)rrs r2env_unmodifiedrs 8 $ % $ $s + + (+c## Sn"SS5n[R[RpTU[R:Xa7[ 5nUR Ul[X&5UlU[lOUnUb U[lU[R:Xa7[ 5nUR Ul[X'5UlU[lO2U[R:XaU=[lnOUnUb U[lU"5n[RS5 Uv U[R:XaUR5UlOXhlU[R:XaUR5UlO"U[R:XaSUlOXxlXEs[l[l[RS5 g!U[R:XaUR5UlOXhlU[R:XaUR5UlO"U[R:XaSUlOXxlXEs[l[l[RS5 f=f7f)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[US5(aSUR;a[nO"[U[5(a[nO[ n[X5(di[US5(a#UR S5nURU5 g[US5(a#URS5nURU5 ggURU5 g)Nmodebdecodezutf-8encode) hasattrrbytesrlrrMr old_writer)r0to_writewanteddecodedrs r2 write_wrappercaptured..write_wrappers 4 SDII%5F g & &FF(++x**"//'2w'8,,OOG,q!- NN8 $r4c\rSrSrSrg)captured..CapturedTextr[Nr?r@rArBrDr[r4r2 CapturedTextrs r4rNzovertaking stderr and stdoutzstderr and stdout yielding back) sysstdoutstderrruryrwriterr rzlogdebuggetvalue) rrrr saved_stdout saved_stderroutfileerrfilecs r2capturedrs:%(  "%SZZ, %%%*#MM 7     CJ %%%*#MM 7  ='' '&& W   CJAII,-5 ])) )'')AHH ])) )'')AH }++ +AHH!- CJ 34 ])) )'')AHH ])) )'')AH }++ +AHH!- CJ 34s D!I<$G(B(I<B)I99I<c## [RnU[lSv U[lg!U[lf=f7frZ)rargv) args_list saved_argss r2rrs+JCH :s?/ ? <?z25.9z26.3zUse `logging._lock` instead.)addendumc## [R"5 Sv [R"5 g![R"5 f=f7frZ)logging _acquireLock _releaseLockr[r4r2 _logger_lockr s3  sA 3A A  A c## [U5nURURURpCn[ 5n[ R  URU5 UR[S-5 SuUlUlSSS5 Sv [ R  URU5 X#sUlUlXAlSSS5 g!,(df  NR=f!,(df  g=f![ R  URU5 X#sUlUlXAlSSS5 f!,(df  f=f=f7f)Nr!)TF) rleveldisabled propagaterr_lock addHandlersetLevelr removeHandler) logger_namelogr_lvl_dsbld_prpgt null_handlers r2disable_loggerrs [ !D::t}}dnn&D=L   % hl#(3% t~ $ ]]   | ,(, %DJ #N] ]W]]   | ,(, %DJ #N]]sfA E 9CE C2E!&C! E CE! C/+E2E&D2) E2 E <EEc## [U5nURURURUR4up4pV[ [ R5nSUlURU5 UR[5 [R URU5 /SSsUlUlUlURU5 URU5 SSS5 Sv [R X4UsUlUlUlXblSSS5 g!,(df  NH=f!,(df  g=f![R X4UsUlUlUlXblSSS5 f!,(df  f=f=f7f)NrF)rhandlersrrrrrrrr setFormatter _FORMATTERrrr)rrr_hndlrsrrrhandlers r2stderr_log_levelr&s [ !D     %!G6 CJJ'GGL U $  e795%4 t}dn   e  $ ]]7>f 4DM4:t}#N] ]W]]7>f 4DM4:t}#N]]sgBF A D!F (E,F <D2 F ! D/+F 2 E<F F E90 F 9 F F  F Fc2[U5n[SUR5S5n[[R 5nSUlURU5 URU=(d [5 U=(d SHnURU5 M [R U(aURU5 URU5 XR5:aURU5 X%lSSS5 g!,(df  g=f)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. c3H# UHoRS:XdMUv M g7f)rN)r)rNrs r2rQ(attach_stderr_handler..XsJ W1I s" "Nrr[)rnextrrrrrrrr addFilterrrrrgetEffectiveLevelr) rrr formatterfiltersrold_stderr_handlernew_stderr_handlerfilter_s r2attach_stderr_handlerr@s, [ !DJ JD 'szz2&&##I$;<=b=$$W-!     1 2 *+ ))+ + MM% " s +AD D)default_returncZ^[(a U"U0UD6$"SS[5mU4Sjn[R"[RU5 [R "U5 U"U0UD6n[R "S5 U$![a Us$f=f!T[4a Us$f=f)zSEnforce a maximum time for a callable to complete. Not yet implemented on Windows. c\rSrSrSrg)!timeout..TimeoutExceptionizr[Nrr[r4r2TimeoutExceptionrzs r4rc>T"5erZr[)signumframers r2 interrupttimeout..interrupt}s "$ $r4r)r#KeyboardInterrupt ExceptionsignalSIGALRMalarm) timeout_secsfuncrr\kwargsrretrs @r2timeoutrmsv "(( (  y  %  fnni0 \" "''C LLOJ!! "! ! ""!"34 "! ! "s#B'B BBB*)B*c0\rSrSrSrSrSrSSjrSrg) DummyExecutoric0SUl[5Ulg)NF) _shutdownr _shutdownLockrgs r2r/DummyExecutor.__init__s!Vr4c$UR UR(a [S5e[5nU"U0UD6nUR U5 UsSSS5 $![ anUR U5 SnAN+SnAff=f!,(df  g=f)Nz*cannot schedule new futures after shutdown)rr RuntimeErrorr set_result BaseException set_exception)r0fnr\rr^resultes r2submitDummyExecutor.submits|   ~~"#OPPA %T,V, V$ ! #"" # s3'BAB A>#A94B9A>>B Bc'D# UHnUH nU"U5v M M g7frZr[)r0r iterablesrSthings r2mapDummyExecutor.maps#!H!5k!""s c^UR SUlSSS5 g!,(df  g=f)NT)rr)r0waits r2shutdownDummyExecutor.shutdowns   !DN  s ,)rrN)T) r?r@rArBr/rrrrDr[r4r2rrs$ " "r4rc8^\rSrSrSU4SjjrU4SjrSrU=r$)ThreadLimitedThreadPoolExecutoric$>[TU]U5 grZ)r.r/)r0 max_workersr1s r2r/(ThreadLimitedThreadPoolExecutor.__init__s %r4cv>[TU]5$![a [UR5S:agef=f)Nr)r._adjust_thread_countrlen_threads)r0r1s r2r4ThreadLimitedThreadPoolExecutor._adjust_thread_counts@ 7/1 1 4==!A% s #88r[) )r?r@rArBr/rrDrErFs@r2r r s&  r4r cn[SSS5n[[RR SU55$)N~z.condazinstrumentation-record.csv!CONDA_INSTRUMENTATION_RECORD_FILE)rr%r}r~r)default_record_files r2get_instrumentation_record_filers3sH.JK  :URU5 [TU] U5$rZ)r!r.ra)r0r^r1s r2ratime_recorder.__call__s! Qw""r4c[RRS5nU(a[U5(a[ 5UlU$)NCONDA_INSTRUMENTATION_ENABLED)r}r~rrr start_time)r0enableds r2rhtime_recorder.__enter__s0**..!@A ww''"fDO r4c|UR(aURn[5nXPR- nURU==S- ss'URU==U- ss'UR 5 [ URS5nURUSUSS35 SSS5 gg!,(df  g=f)Nr!a,r^rK) r'rrtotal_call_numtotal_run_time _ensure_diropen record_filer)r0rorprqrend_timerun_timefhs r2rrtime_recorder.__exit__s ??JvH//1H    +q 0 +    +x 7 +    d&&,J !3!3!8!8!:;J HH%"":."":.  )r?r@rArBrr1r'rintr-floatr.r/r!rarhrr classmethodr;rr/rDrErFs@r2rrse13KJ %N 'N')# 9  33r4rc [5n[[5n0n[U5(dg[ U5nUH@nUR 5R S5upVXR[U55 MB SSS5 [U5H)nXn[U5n[U5nXh- n UUU S.X%'M+ [[R"USSSS95 g!,(df  Ng=f)Nr,)counts total_time average_timeTr)r,z: ) sort_keysrP separators)rrlistrr0stripsplitappendrAr8rsumprintrdumps) r1 grouped_data final_datar4linerrE all_timesrDrFs r2print_instrumentation_datarTs13Kt$LJ +   k bD%)ZZ\%7%7%< "J  $ + +E*,= >  \*  , Y^ !* $("  + $**Z4k RS!  s AC  C.__main__)r)NNNr>rZ)VrCrr}rr collectionsrconcurrent.futuresrrrr contextlibrenumr rkr r functoolsr r iorrrrrrros.pathrrrr threadingrrauxlib.decoratorsr auxlib.logzrauxlib.type_coercionrcommon.serializer deprecationsr compatr"r# constantsr$pathr%r?rrrr&IS_INTERACTIVEr(r~rrrTrVrdswallow_broken_piperurrrryrrrrrrrrr rrrTr[r4r2rhs4 #QQ%"$ GG00-%*#%.X.F3::3D3D3F&I&2 2::>>/ 011& GJ FJ J   ("()D""6  !((1E1E[5[5| FF%CDE$$"$$4   *#Z7;">"H"<&8$ =3$=3@T8 z r4