B °F.\(ã@s*ddlmZmZmZddlZddlZddlZddlZddlZddl Z ddl m Z ej j Z ej  ej  e¡d¡Zej jedeeƒZe  e¡ZWdQRXej  e¡ddd d d d d ddddddddddddddddddd d!d"d#œZej  e¡e e¡Zd$d%„Zd&d'„Zd(d)„Zd*d+„Z e ej j ƒdS),é)Úprint_functionÚdivisionÚabsolute_importNé)Ú logging_nameszdistributed.yaml)Úsourcez&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-lengthzdistributed.admin.log-formatzdistributed.admin.pdb-on-err)zallowed-failuresZ bandwidthzdefault-data-sizeztransition-log-lengthz work-stealingz worker-ttlzmultiprocessing-methodzuse-file-lockingzprofile-intervalzprofile-cycle-intervalzworker-memory-targetzworker-memory-spillzworker-memory-pausezworker-memory-terminatezheartbeat-intervalZ compressionzconnect-timeoutz tcp-timeoutzdefault-schemezsocket-backlogzrecent-messages-log-lengthzdiagnostics-linkzbokeh-export-toolz tick-timeztick-maximum-delayz log-lengthz log-formatz pdb-on-errcCs¬ddddddœ}| | di¡¡t tj¡}| t tj jd|d¡¡x\|  ¡D]P\}}t |t ƒrrt | ¡}t |¡}| |¡g|jd d …<| |¡d |_qTWd S) z÷ Initialize logging using the "old-style" configuration scheme, e.g.: { 'logging': { 'distributed': 'info', 'tornado': 'critical', 'tornado.application': 'error', } } ÚinfoZwarningZcriticalÚerror)Z distributedzdistributed.clientZbokehZtornadoztornado.applicationÚloggingzdistributed.admin.log-format)ÚconfigNF)ÚupdateÚgetr Z StreamHandlerÚsysÚstderrZ setFormatterZ FormatterÚdaskr ÚitemsÚ isinstanceÚstrrÚupperÚ getLoggerZsetLevelZhandlersZ addHandlerZ propagate)r ZloggersZhandlerÚnameÚlevelÚlogger©rú1lib/python3.7/site-packages/distributed/config.pyÚ_initialize_logging_old_styleHs"        rcCstj | d¡¡dS)z« Initialize logging using logging's "Configuration dictionary schema". (ref.: https://docs.python.org/2/library/logging.config.html#logging-config-dictschema) r N)r r Z dictConfigr )r rrrÚ_initialize_logging_new_styleisrcCstjj| d¡dddS)z¥ Initialize logging using logging's "Configuration file format". (ref.: https://docs.python.org/2/library/logging.config.html#configuration-file-format) zlogging-file-configF)Zdisable_existing_loggersN)r r Z fileConfigr )r rrrÚ_initialize_logging_file_configqsrcCs\d|kr"d|krtdƒ‚t|ƒn6| di¡}d|krPt|dƒ|d<t|ƒnt|ƒdS)Nzlogging-file-configr zJConfig options 'logging-file-config' and 'logging' are mutually exclusive.Úversion)Ú RuntimeErrorrr Úintrr)r Z log_configrrrÚinitialize_loggingys   r!)!Z __future__rrrr Zlogging.configÚosrrZyamlZ compatibilityrr ÚpathÚjoinÚdirnameÚ__file__ÚfnZ ensure_fileÚopenÚfÚloadÚdefaultsZupdate_defaultsÚaliasesÚrenamerÚ__name__rrrrr!rrrrÚs`    !