U /e@sLddlmZddlZddlZddlZddlZddlZddlZddlZddl m Z ddl m Z m Z ejjZejejedZeeZeeZW5QRXejedddd d d d d ddddddddddddddddddd d!d"d#d$ZejeeeZd%d&Zd'd(Zd)d*Z d+d,Z!d-d.Z"d/d0Z#e"ejje#ejjdS)1) annotationsN)import_required)WINDOWS logging_nameszdistributed.yamlz&distributed.scheduler.allowed-failureszdistributed.scheduler.bandwidthz'distributed.scheduler.default-data-sizez+distributed.scheduler.transition-log-lengthz#distributed.scheduler.work-stealingz distributed.scheduler.worker-ttlz)distributed.worker.multiprocessing-methodz#distributed.worker.use-file-lockingz#distributed.worker.profile.intervalz distributed.worker.profile.cyclez distributed.worker.memory.targetzdistributed.worker.memory.spillzdistributed.worker.memory.pausez#distributed.worker.memory.terminatezdistributed.client.heartbeatzdistributed.comm.compressionz!distributed.comm.timeouts.connectzdistributed.comm.timeouts.tcpzdistributed.comm.default-schemezdistributed.comm.socket-backlogz+distributed.comm.recent-messages-log-lengthzdistributed.dashboard.linkz!distributed.dashboard.export-toolzdistributed.admin.tick.intervalzdistributed.admin.tick.limitzdistributed.admin.log-lengthdistributed.admin.log-formatzdistributed.admin.pdb-on-errzdistributed.comm.ucxzdistributed.rmm)zallowed-failures bandwidthzdefault-data-sizeztransition-log-lengthz work-stealingz worker-ttlzmultiprocessing-methodzuse-file-lockingzprofile-intervalzprofile-cycle-intervalzworker-memory-targetzworker-memory-spillzworker-memory-pausezworker-memory-terminatezheartbeat-interval compressionzconnect-timeoutz tcp-timeoutzdefault-schemezsocket-backlogzrecent-messages-log-lengthzdiagnostics-linkzbokeh-export-toolz tick-timeztick-maximum-delayz log-lengthz log-formatz pdb-on-errZucxZrmmc Csdddddd}t|}||dittj}|tt j jd|d| D]\}}t |t rxt|}t|}||d }d }|d D]4} |d krt| }n || ||jkrd }qq|sZ||qZd S) z Initialize logging using the "old-style" configuration scheme, e.g.: { 'logging': { 'distributed': 'info', 'tornado': 'critical', 'tornado.application': 'error', } } infowarningerrorcritical) distributedzdistributed.clientZbokehtornadoztornado.applicationloggingr)configNF.T)_find_logging_configupdategetr StreamHandlersysstderr setFormatter Formatterdaskritems isinstancestrrupper getLoggersetLevelsplitgetChildhandlers addHandler) rloggers base_confighandlernamelevelloggerZancZalready_registeredZancestorr+6/tmp/pip-unpacked-wheel-g426oqom/distributed/config.py_initialize_logging_old_styleGs<         r-cCst|}tj|ddS)z Initialize logging using logging's "Configuration dictionary schema". (ref.: https://docs.python.org/3/library/logging.config.html#configuration-dictionary-schema) rN)rrr dictConfigrrr&r+r+r,_initialize_logging_new_styleysr0cCs"t|}tjj|ddddS)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)rrr fileConfigrr/r+r+r,_initialize_logging_file_configs r4cCs,ddh}||di@r$|dS|SdS)z Look for the dictionary containing logging-specific configurations, starting in the 'distributed' dictionary and then trying the top-level r1rr N)rkeys)rZ logging_keysr+r+r,rsrcCsdt|}d|kr*d|kr tdt|n6|di}d|krXt|d|d<t|nt|dS)Nr1rzJConfig options 'logging-file-config' and 'logging' are mutually exclusive.version)r RuntimeErrorr4rintr0r-)rr&Z log_configr+r+r,initialize_loggings   r9cCs\tjd}|dkr(tdd}|n0|dkrDtrXttnt dtjddS)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>asynciorzWExpected distributed.admin.event-loop to be in ('asyncio', 'tornado', 'uvloop'), got %s) rrrrinstallrr;Zset_event_loop_policyZWindowsSelectorEventLoopPolicy ValueError)rZ event_loopr:r+r+r,initialize_event_loops   r>)$ __future__rr;rlogging.configosrZyamlrZ dask.utilsrZdistributed.compatibilityrrrpathjoindirname__file__fnopenfZ safe_loaddefaultsZupdate_defaultsaliasesrenamer__name__r*r-r0r4rr9r>r+r+r+r,sn    ! 2