+ :1j%Rt^RIHt^RIt^RIt^RIt^RIHt^RIH t ^RI H t H t H t Ht^RIHt^RIHt^RIHt] 'd%^R IHtHt^R IHt^R IHt^R IHtHt]!R 4t]P>!] 4t!]"!]4t#^ t$RRlt%RRRllt&RRlt'RRlt(]PRRRl4t*RRRllt+RRlt,Rt-R#)z Miscellaneous utility functions for sharded repodata processing. This module contains utility functions that don't fit cleanly into other modules: - URL handling - Package name parsing - Data transformation helpers - Threading utilities ) annotationsN)suppress) TYPE_CHECKING)urljoinurlparse urlunparse uses_relative)context)InvalidMatchSpec) MatchSpec)IteratorSequence) SimpleQueue)TypeVar)PackageRecordDict ShardDict_TcV^8dQhRR/#)returnint)formats":lib/python3.14/site-packages/conda/_private/shards/misc.py __annotate__r,s&&S&cR\Pe\P#\#)a If context.repodata_threads is not set, find the size of the connection pool in a typical https:// session. This should significantly reduce dropped connections. We match requests' default 10. Is this shared between all sessions? Or do we get a different pool for a different get_session(url)? Other adapters (file://, s3://) used in conda would have different concurrency behavior; we are not prepared to have separate threadpools per connection type. )r repodata_threadsSHARDS_CONNECTIONS_DEFAULTrrr_shards_connectionsr,s"+''' %%rc$V^8dQhRRRRRR/#)rbase_urlstr relative_urlrr)rs"rrr>s!//s/#/s/rcL\V4p\V4pVP\9d,VP'dTpM\\W4R4pMVP'dTpMVP'grVP'd`\ VP RR74p\\WQ4R4p\ \V4P VPR74pM\\W4R4pVP R4'g VR, pV#)a Join base_url with relative_url, ensuring proper handling of all URL schemes. Python's urllib.parse.urljoin only handles schemes registered in ``urllib.parse.uses_relative``. For unregistered schemes like ``s3://``, it returns just ``"."`` instead of the resolved URL. This function falls back to a scheme-swap workaround for those cases. The result always ends with "/" to enable proper string concatenation with filenames. See: https://github.com/conda/conda-libmamba-solver/issues/866 .https)scheme/)rr'_URLJOIN_SAFE_SCHEMESrr_replaceendswith)r!r#parsedrelative_parsedresulthttps_base_url joined_httpss&& r_safe_urljoin_with_slashr1>sh F|,O}}--  ! ! !!FWX#H#NL 6 ? ?v}} ? UVFWXB/B>,B+?B>B($B>'B((B>+ B; 6B>cFa\P!S4V3Rl4pV#)zJ Decorator to send unhandled exceptions to the second argument out_queue. c<S!W.VO5/VB# \d.pTPR4TPT4Rp?R#Rp?ii;i)N) BaseExceptionput)rZ out_queueargskwargsefuncs&&*, rwrapper#exception_to_queue..wrappersH =d=f= =  LL  MM!   s  A"AA) functoolswraps)rnrosf rexception_to_queuerss' __T Nr))F).__doc__ __future__rrqloggingr] contextlibrtypingr urllib.parserrrrconda.base.contextr conda.exceptionsr conda.models.match_specr collections.abcr r rQueuerconda._private.shards.typingrrr getLogger__name__rG frozensetr)rrr1r7rBcacherIrXrersrrrrs#  EE&--2*I B!"-0&$/d    6< r