r> \#"\?5r@\A"\RS5=(a \RR5rD"SS\!5rE\5"\RRS55(a \E"S5rHO\!"S5rHSFSjrI"S S!5rJ"S"S#\J5rK\K"5rL"S$S%\5rM\SGS&j5rN\SHS'j5rO\SIS(j5rP\\MR\MR4S)j5rR\S*5rS\7"S+S,S-S.9\S/55rT\S05rU\SIS1j5rV\ SS2SS4S3jrWSS4.S5jrX\7"S6S+S7S.9"S8S955rY\7"S6S+S:S.9"S;S<55rZ"S=S>\ 5r["S?S@\ 5r\\ r SAr]"SBSC\J5r^SDr_\?SE:Xa\_"5 gg)JzCommon I/O utilities.N) defaultdict)ExecutorFutureThreadPoolExecutor_base as_completed) _WorkItem)contextmanager)Enum)EPIPE ESHUTDOWN)partialwraps)BytesIOStringIO)cycle)CRITICALWARN Formatter StreamHandler getLogger)dirnameisdirisfilejoin)EventLockRLockThread)sleeptime) memoizemethod) NullHandler)boolify) 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__)selfr1r2 __class__s /lib/python3.13/site-packages/conda/common/io.pyr5DeltaSecondsFormatter.__init__0s S2c>[5nURn[URU5UlX#- UlURS- Ul[ TU]U5$)Ni)r!r3max delta_secsrelativeCreatedrelative_created_secsr4format)r6recordnowr3r7s r8r@DeltaSecondsFormatter.format4sQfNN T^^S1O'-'='='D$w~f%%r:)r3NN) __name__ __module__ __qualname____firstlineno____doc__r5r@__static_attributes__ __classcell__r7s@r8r.r.$s 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)sc8^SRU4SjU55$)Nc3R># UHnSST--S-[U5-v M g7f)  z- N)str).0xindents r8 dashlist..Is(I14#,&-A6s$')r)iterablerVs `r8dashlistrZHs 77II IIr:c\rSrSrSrSrSrg)ContextDecoratorLzqBase 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)argskwdsfr6s r8 decorated,ContextDecorator.__call__..decoratedTs$'$'s $)r)r6rdres`` r8__call__ContextDecorator.__call__Ss! q (  (r:raN)rErFrGrHrIrgrJrar:r8r\r\Ls  r:r\c \rSrSrSrSrSrg)SwallowBrokenPipe\cgr`rar6s r8 __enter__SwallowBrokenPipe.__enter__`s r:cU(aE[U[5(a/[USS5(aUR[[ 4;aggggg)NerrnoT) isinstanceEnvironmentErrorgetattrrqr r r6exc_typeexc_valexc_tbs r8__exit__SwallowBrokenPipe.__exit__csJ 7$455$// %!33406 r:raN)rErFrGrHrnryrJrar:r8rjrj\s  r:rjc \rSrSrSrSrSrSrg) CaptureTargetpz{Constants used for contextmanager captured. Used similarly like the constants PIPE, STDOUT for stdlib's subprocess.Popen. raN)rErFrGrHrISTRINGSTDOUTrJrar:r8r|r|ps F Fr:r|c## 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 r8env_varsrzs$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 r8env_varrs) A !~ F" G F Fs/ / ,/c#Z# [US9nUv SSS5 g!,(df  g=f7f)N)rr)rrs r8env_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) hasattrrbytesrrrrSr old_writer)r6to_writewanteddecodedrs r8 write_wrappercaptured..write_wrappers 4 SDII%5F g & &FF(++x**"//'2w'8,,OOG,q!- NN8 $r:c\rSrSrSrg)captured..CapturedTextraNrErFrGrHrJrar:r8 CapturedTextrs r:rNzovertaking stderr and stdoutzstderr and stdout yielding back) sysstdoutstderrr|rrwriterrrlogdebuggetvalue) rrrr saved_stdout saved_stderroutfileerrfilecs r8capturedrs:%(  "%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=f7fr`)rargv) args_list saved_argss r8rrs+JCH :s?/ ? <?z25.9z26.3zUse `logging._lock` instead.)addendumc## [R"5 Sv [R"5 g![R"5 f=f7fr`)logging _acquireLock _releaseLockrar:r8 _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 propagater$r_lock addHandlersetLevelr removeHandler) logger_namelogr_lvl_dsbld_prpgt null_handlers r8disable_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 r8stderr_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 Fc0[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)rTrs r8rW(attach_stderr_handler..ZsJ W1I s" "Nrra)rnextrrrrrrrr addFilterrrrrgetEffectiveLevelr) rrr formatterfiltersrold_stderr_handlernew_stderr_handlerfilter_s r8attach_stderr_handlerrBs, [ !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..TimeoutExceptioni|raNrrar:r8TimeoutExceptionr|s r:rc>T"5er`ra)signumframers r8 interrupttimeout..interrupts "$ $r:r)r)KeyboardInterrupt ExceptionsignalSIGALRMalarm) timeout_secsfuncrrbkwargsrretrs @r8timeoutrosv "(( (  y  %  fnni0 \" "''C LLOJ!! "! ! ""!"34 "! ! "s#B'B BBB*)B*z25.3z*Use `conda.reporters.get_spinner` instead.cZ\rSrSrSr\"S5rS SjrSrSr Sr \ S5r S r S rg ) Spinneriz Args: message (str): A message to prefix the spinner with. The string ': ' is automatically appended. enabled (bool): If False, usage is a no-op. json (bool): If True, will not output non-json to stdout. z/-\|c<XlX lX0l[5Ul[ UR S9Ul[[UR55S-Ul [RUlU=(a U(+=(a [UlX@lg)N)targetr')messageenabledjsonr _stop_runningr_start_spinning_spinner_threadlenr spinner_cycle_indicator_lengthrrfhIS_INTERACTIVE show_spin fail_message)r6rrrrs r8r5Spinner.__init__so   "W%T-A-AB!$T$*<*<%=!>!B** @X@.(r:cUR(aURR5 gUR(d6URR S5 URR 5 gg)Nz...working... )rrstartrrrflushrms r8r  Spinner.startsE >>  & & ( GGMM* + GGMMOr:cUR(a<URR5 URR 5 SUlggNF)rrsetrrrms r8stop Spinner.stops9 >>    " " $  % % '"DN r:cURR5(dURR[ UR 5S-5 URR 5 [S5 URRSUR-5 URR5(dMgg![a5nUR[[4;aUR5 SnAgeSnAff=f)NrRg?)ris_setrrrrr r rOSErrorrqr r r)r6es r8rSpinner._start_spinnings ((//11 d4#5#56<= d  dT%;%;;< ((//11  ww5),,   sBProgressBar.close*s <<yy]]_JJ$$%d&6&6%77fgJJ$$& %_   !   + $_s A C CcSSKJn U"U0UD6$)z=Deferred import so it doesn't hit the `conda activate` paths.r)tqdm) tqdm.autorA)rbrrAs r8r,ProgressBar._tqdm8s #T$V$$r:)r+rrr-)TFNT)rErFrGrH classmethodr!r5r5r8r;rr> staticmethodr,rJrar:r8rrs[ KO(AT$  , ,%%r:rc0\rSrSrSrSrSrSSjrSrg) DummyExecutoriAc0SUl[5Ulgr ) _shutdownr _shutdownLockrms r8r5DummyExecutor.__init__Bs!Vr:c$UR UR(a [S5e[5nU"U0UD6nUR U5 UsSSS5 $![ anUR U5 SnAN+SnAff=f!,(df  g=f)N*cannot schedule new futures after shutdown)rJrI RuntimeErrorr set_result BaseException set_exception)r6fnrbrrdresultrs r8submitDummyExecutor.submitFs|   ~~"#OPPA %T,V, V$ ! #"" # s3'BAB A>#A94B9A>>B Bc'D# UHnUH nU"U5v M M g7fr`ra)r6r iterablesrYthings r8mapDummyExecutor.mapUs#!H!5k!""s c^UR SUlSSS5 g!,(df  g=f)NT)rJrI)r6waits r8shutdownDummyExecutor.shutdownZs   !DN  s ,)rIrJN)T) rErFrGrHr5rTrYr]rJrar:r8rGrGAs$ " "r:rGc2^\rSrSrSU4SjjrSrSrU=r$)ThreadLimitedThreadPoolExecutori_c$>[TU]U5 gr`)r4r5)r6 max_workersr7s r8r5(ThreadLimitedThreadPoolExecutor.__init__`s %r:czUR UR(a [S5e[R"5n[ XAX#5nUR RU5 UR5 UsSSS5 $![a [UR5S:aN0ef=f!,(df  g=f)a This is an exact reimplementation of the `submit()` method on the parent class, except with an added `try/except` around `self._adjust_thread_count()`. So long as there is at least one living thread, this thread pool will not throw an exception if threads cannot be expanded to `max_workers`. In the implementation, we use "protected" attributes from concurrent.futures (`_base` and `_WorkItem`). Consider vendoring the whole concurrent.futures library as an alternative to these protected imports. https://github.com/agronholm/pythonfutures/blob/3.2.0/concurrent/futures/thread.py#L121-L131 # NOQA https://github.com/python/cpython/blob/v3.6.4/Lib/concurrent/futures/thread.py#L114-L124 rMrN) _shutdown_lockrIrNrrr _work_queueput_adjust_thread_countr_threads)r6rRrbrrdws r8rT&ThreadLimitedThreadPoolExecutor.submitcs ~~"#OPP A!.A     # ))+'!   t}}%) ! s0AB,'B7B,#B)%B,'B))B,, B:ra) )rErFrGrHr5rTrJrKrLs@r8r`r`_s&!!r:r`cn[SSS5n[[RR SU55$)N~z.condazinstrumentation-record.csv!CONDA_INSTRUMENTATION_RECORD_FILE)rr+rrr)default_record_files r8get_instrumentation_record_filerqs3sH.JK  :URU5 [TU] U5$r`)r{r4rg)r6rdr7s r8rgtime_recorder.__call__s! Qw""r:c[RRS5nU(a[U5(a[ 5UlU$)NCONDA_INSTRUMENTATION_ENABLED)rrrr%r! start_time)r6rs r8rntime_recorder.__enter__s0**..!@A ww''"fDO r:c|UR(aURn[5nXPR- nURU==S- ss'URU==U- ss'UR 5 [ URS5nURUSUSS35 SSS5 gg!,(df  g=f)Nr'a,rdrQ) rrur!total_call_numtotal_run_time _ensure_diropen record_filer)r6rvrwrxruend_timerun_timers r8rytime_recorder.__exit__s ??JvH//1H    +q 0 +    +x 7 +    d&&,J !3!3!8!8!:;J HH%"":."":.    \*  , Y^ !* $("  + $**Z4k RS!  s AC  C.__main__)r")NNNrDr`)`rIrrrrr collectionsrconcurrent.futuresrrrrrconcurrent.futures.threadr contextlibr enumr rqr r functoolsrriorr itertoolsrrrrrros.pathrrrr threadingrrrrr!r auxlib.decoratorsr# auxlib.logzr$auxlib.type_coercionr% deprecationsr&compatr(r) constantsr*pathr+rErrrr,rr.rrrrZr\rjrr|rrrrrrrrrrrrrrGr`rqrsrrar:r8rs  #XX/%"$ GG0000-%*%.X.F3::3D3D3F&I&2 2::>>/ 011& GJ FJ J   ("()D""6  !((1E1E[5[5| FF%CDE$$"$$4   *#Z7;"<   9 D#D#  D#N   > _%_%  _%F"H"<%&8%P =3$=3@T8 z r: