ԋgddlmZddlZddlZddlZddlZddlmZddl m Z ddl Z ddl Z ddl mZe jjZej j#ej j%edZee5Ze j.eZddde jj3eiddd d d d d ddddddddddddddddddd d!d"d#d$d%d&d'd(id)d*d+d,d-d.d/d0d1d2d3d4d5d6d7d8d9d:d;d<d=d>d?d@dAd@dBd@dCd@dDd@dEdFZe jj7ee jj4j9eej:eZej@dGk\r ejBZ"ndOdHZ"dPdIZ#dPdJZ$dPdKZ%dQdLZ&dPdMZ'dRdNZ(e'e jjy#1swY6xYw)S) annotationsN)Callable)Any)import_requiredzdistributed.yamlzallowed-failuresz&distributed.scheduler.allowed-failures bandwidthzdistributed.scheduler.bandwidthzdefault-data-sizez'distributed.scheduler.default-data-sizez work-stealingz#distributed.scheduler.work-stealingz worker-ttlz distributed.scheduler.worker-ttlzmultiprocessing-methodz)distributed.worker.multiprocessing-methodzuse-file-lockingz#distributed.worker.use-file-lockingzprofile-intervalz#distributed.worker.profile.intervalzprofile-cycle-intervalz distributed.worker.profile.cyclezworker-memory-targetz distributed.worker.memory.targetzworker-memory-spillzdistributed.worker.memory.spillzworker-memory-pausezdistributed.worker.memory.pausezworker-memory-terminatez#distributed.worker.memory.terminatezheartbeat-intervalzdistributed.client.heartbeat compressionzdistributed.comm.compressionzconnect-timeoutz!distributed.comm.timeouts.connectz tcp-timeoutzdistributed.comm.timeouts.tcpzdefault-schemezdistributed.comm.default-schemezsocket-backlogzdistributed.comm.socket-backlogzdiagnostics-linkzdistributed.dashboard.linkzbokeh-export-toolz!distributed.dashboard.export-toolz tick-timezdistributed.admin.tick.intervalztick-maximum-delayzdistributed.admin.tick.limitz log-lengthzdistributed.admin.log-lengthz log-formatdistributed.admin.log-formatz pdb-on-errzdistributed.admin.pdb-on-errucxzdistributed.comm.ucxrmmzdistributed.rmmztransition-log-lengthz&distributed.admin.low-level-log-lengthz+distributed.scheduler.transition-log-lengthz'distributed.scheduler.events-log-lengthzrecent-messages-log-lengthz+distributed.comm.recent-messages-log-lengthzdistributed.p2p.diskzdistributed.p2p.storage.disk) c>tjjS)N)logging _nameToLevelcopy2lib/python3.12/site-packages/distributed/config.py _logging_get_level_names_mappingrSs##((**rcddddddd}t|}|j|jditjt j }|jtjtjjd|t}t|jD]\}}t|tr||j!n|}tj"|}|j%|tj"d } d } |j'd D]#} | j(rd } n| j+| %| r|j-|d |_y ) z Initialize logging using the "old-style" configuration scheme, e.g.: { 'logging': { 'distributed': 'info', 'tornado': 'critical', 'tornado.application': 'error', } } infowarningerrorcritical) distributedzdistributed.clientzdistributed.gcbokehtornadoztornado.applicationrr )configNF.T)_find_logging_configupdategetr StreamHandlersysstderr setFormatter Formatterdaskrrsorteditems isinstancestrupper getLoggersetLevelsplithandlersgetChild addHandler propagate) rloggers base_confighandler logging_namesname raw_levellevelloggerancalready_registeredancestors r_initialize_logging_old_styler@WsL'#& %G'v.K NN;??9b12##CJJ/G  KKOO:6O J  56M!'--/2i)S) )//+ ,  ""4(%" 3H||%)" LL " ( "   g &$F +3rcvt|}tjj|j dy)z Initialize logging using logging's "Configuration dictionary schema". (ref.: https://docs.python.org/3/library/logging.config.html#configuration-dictionary-schema) rN)r rr dictConfigr"rr6s r_initialize_logging_new_stylerDs) 'v.K NNkooi89rczt|}tjj|j ddy)z Initialize logging using logging's "Configuration file format". (ref.: https://docs.python.org/3/howto/logging.html#configuring-logging) logging-file-configF)disable_existing_loggersN)r rr fileConfigr"rCs r_initialize_logging_file_configrIs5 'v.K NN-.!&rc^ddh}||jdijzr|dS|S)z Look for the dictionary containing logging-specific configurations, starting in the 'distributed' dictionary and then trying the top-level rFrr)r"keys)r logging_keyss rr r s: *95Lfjj388::m$$ rct|}d|vrd|vr tdt|y|jdi}d|vrt |d|d<t |yt |y)NrFrzJConfig options 'logging-file-config' and 'logging' are mutually exclusive.version)r RuntimeErrorrIr"intrDr@)rr6 log_configs rinitialize_loggingrRsr&v.K +  #\  (/ __Y3  "$' 9(=$>Jy ! )& 1 )& 1rc tjjd}|dk(rtdd}|jS|dvr$t j dk(rtjSytdtjjdz)Nzdistributed.admin.event-loopuvloopzThe distributed.admin.event-loop configuration value is set to 'uvloop' but the uvloop module is not installed Please either change the config value or install one of the following conda install uvloop pip install uvloop>asynciorwin32zWExpected distributed.admin.event-loop to be in ('asyncio', 'tornado', 'uvloop'), got %s) r(rr"rnew_event_loopr$platformrUSelectorEventLoop ValueError) event_looprTs rget_loop_factoryr\s!?@JX  % $$$++ <<7 ",, , a ++//8 9 : r)returnzdict[str, int])rdict[Any, Any]r]None)rr^r]r^)r]z.Callable[[], asyncio.AbstractEventLoop] | None)) __future__rrUlogging.configrosr$collections.abcrtypingryamlr( dask.utilsrrpathjoindirname__file__fnopenf safe_loaddefaultsupdate_defaults deprecationsrenamer!r.__name__r< version_infogetLevelNamesMappingrr@rDrIr rRr\rrrrvs" $ &   WW\\"''//(+-?@ "Xt~~a H H%$@$2$B$: $ 4 $ I $=$=$@$>$<$<$D$8$1$ :!$"2#$$7%$&7'$(4)$*<+$,2-$.8/$001$203$405$6 !7$8 9$<E=$>23[?$@./WA$B!"JC$D23[E$F:G$ P <   -   8 $w'.'C'C$+2%j:  2$44;;%%&KXs G  G