ó P'—^c @@s!dZddlmZmZddlZddlZddlZddlZddlZddl Z ddl m Z ddl m Z mZddlmZddlmZmZddlmZdd lmZmZd d lmZd d dddddddddg Zeaej ddkZ!ej"j#deƒZ$edƒZ%Z&edƒZ'ea(d„Z)d„Z*e d„ƒZ+dd„Z,d „Zed!ƒZ-ed"ƒZ.d#„Z/d$„Z0d ej1fd%„ƒYZ2d e3fd&„ƒYZ4ed'„Z5d(„Z6d)„Z7d d*„Z8e5ƒdS(+sD celery.utils.log ~~~~~~~~~~~~~~~~ Logging utilities. i(tabsolute_importtprint_functionN(tcontextmanager(tcurrent_processtutil(tvalues(t get_loggert LOG_LEVELS(tsafe_str(tstring_tttext_ti(tcoloredtColorFormattert LoggingProxyt base_loggertset_in_sighandlert in_sighandlerRtget_task_loggertmleveltensure_process_aware_loggertget_multiprocessing_loggertreset_multiprocessing_loggeritMP_LOGtcelerytmultiprocessingcC@s |adS(N(t_in_sighandler(tvalue((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR2scc@s±tƒ}tttjjjƒƒtjdƒg}xv|D]n}yTxM|j D]B}y(||kr{|j V|j |ƒnWqNt k rqNXqNWWq;t k r¨q;Xq;WdS(N( tsettlistRtloggingtLoggertmanagert loggerDictt getLoggertNonethandlerststreamtaddtAttributeError(tseentloggerstloggerthandler((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytiter_open_logger_fds7s      cc@s%ttƒz dVWdttƒXdS(N(RtTruetFalse(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRHs  iècC@s”|tƒ}}x}t|ƒD]Z}||kr3tS||krWtdj|ƒƒ‚n|j|ƒ|j}|sPqqWtdj|ƒƒ‚tS(NsLogger {0!r} parents recursivesLogger hierarchy exceeds {0}(RtrangeR,t RuntimeErrortformatR%tparentR-(tltptmaxtthisR't_((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyt logger_isaQs    cC@sRt|ƒ}tj||jfkrN|tk rNt|tƒsNt|_qNn|S(N(t _get_loggerRtrootR1RR7(tnameR2((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRds  $s celery.tasks celery.workercC@s+t|ƒ}t|tƒs't|_n|S(N(RR7t task_loggerR1(R:R)((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRns  cC@s+|r't|tjƒ r't|jƒS|S(N(t isinstancetnumberstIntegralRtupper(tlevel((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRuscB@sgeZeƒjZiedd6edd6edd6edd6Zd ed„Zd „Z d „Z RS( tbluetDEBUGtyellowtWARNINGtredtERRORtmagentatCRITICALcC@s tjj||ƒ||_dS(N(Rt Formattert__init__t use_color(tselftfmtRK((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRJscC@s^|r%t|tƒ r%tjƒ}ntjj||ƒ}t|tƒrZt rZt |ƒS|S(N( R<ttupletsystexc_infoRRItformatExceptiontstrtPY3R(RLteitr((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRQ…s  cC@s9tjj||ƒ}|jj|jƒ}|jdkrEtjƒn|j}|r+|jr+yXy9t |t ƒrˆt |t |ƒƒƒSt ||ƒƒSWnt k r³t |ƒSXWq5tk r'}|jddjt|ƒ|ƒ}|_|_ztjj||ƒSWd|||_|_Xq5Xn t |ƒSdS(Nis(RRIR0tcolorstgett levelnameRPRORKR<R R RtUnicodeDecodeErrort Exceptiontmsgttype(RLtrecordR[tcolorteinfotexctprev_msg((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR0s$$  N( t__name__t __module__R tnamestCOLORSRVR"R,RJRQR0(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR {s   cB@sweZdZdZd ZeZej Z e j ƒZ d d„Zd„Zd„Zd„Zd„Zd„Zd„ZRS( sÂForward file object to :class:`logging.Logger` instance. :param logger: The :class:`logging.Logger` instance to forward to. :param loglevel: Loglevel to use when writing messages. twcC@s;||_t|p$|jjp$|jƒ|_|jƒdS(N(R)RR@tloglevelt_safewrap_handlers(RLR)Rg((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRJ»s $cC@s,d„}g|jjD]}||ƒ^qS(s‡Make the logger handlers dump internal errors to `sys.__stderr__` instead of `sys.stderr` to circumvent infinite loops.cS@s,dtjfd„ƒY}|ƒj|_dS(NtWithSafeHandleErrorcB@seZd„ZRS(cS@s[tjƒ}zDy,tj|d|d|ddtjƒWntk rNnXWd~XdS(Niii(RORPt tracebacktprint_exceptionR"t __stderr__tIOError(RLR]RP((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyt handleErrorÉs   (RbRcRn(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRiÇs(RtHandlerRn(R*Ri((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyt wrap_handlerÅs(R)R#(RLRpth((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRhÀs cC@s—trtt|ƒdtjƒSt|jdtƒr8dS|jƒ}|r“|j r“t |j_ z |j j |jt|ƒƒWdt|j_ XndS(s Write message to logging object.tfiletrecurse_protectionN(RtprintRRORltgetattrt_threadR-tstriptclosedR,RsR)tlogRg(RLtdata((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytwriteÙs   cC@s"x|D]}|j|ƒqWdS(så`writelines(sequence_of_strings) -> None`. Write the strings to the file. The sequence can be any iterable object producing strings. This is equivalent to calling :meth:`write` for each string. N(R{(RLtsequencetpart((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyt writelinesès cC@sdS(sNThis object is not buffered so any :meth:`flush` requests are ignored.N((RL((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytflushôscC@s t|_dS(saWhen the object is closed, no write requests are forwarded to the logging object anymore.N(R,Rx(RL((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytcloseùscC@stS(s9Always return :const:`False`. Just here for file support.(R-(RL((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytisattyþsN(RbRct__doc__tmodeR"R:R-RxRRFRgt threadingtlocalRvRJRhR{R~RR€R(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR ®s       c@s|s t r}tjƒzUtatjƒ‰tˆdtƒrBdSdˆf‡fd†ƒY}tj|ƒWdtjƒXndS(s9Make sure process name is recorded when loggers are used.t_process_awareNtProcessAwareLoggerc@s2eZeZeZ‡fd†Z‡fd†ZRS(c@s(ˆj|||Ž}tƒj|_|S(N(t makeRecordRt_namet processName(RLtargstkwdsR](R(s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRˆsc@str dSˆj|||ŽS(N(RRy(RLR‹tkwargs(R(s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRys(RbRcR,t _signal_safeR†RˆRy((R(s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR‡s( R†Rt _acquireLockR,tgetLoggerClassRuR-tsetLoggerClasst _releaseLock(tforceR‡((Rs2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyRs    cC@strtjƒSdS(N(tmputilRR"(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR scC@s%tr!ttdƒr!dt_ndS(Nt_logger(R”thasattrR"R•(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pyR$scC@s7tr3ttƒddƒ}|dk r/||S|SdS(Ntindex(RRuR"(tbaseR—((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytcurrent_process_index)s(9R‚t __future__RRRR=tosROR„Rjt contextlibRtbilliardRRR”t kombu.fiveRt kombu.logRR8Rtkombu.utils.encodingRt celery.fiveR R ttermR t__all__R-R†t version_infoRStenvironRWRRR)t mp_loggerRRR+RR7R;t worker_loggerRRRIR tobjectR RRRR™(((s2/tmp/pip-unpacked-wheel-gV1wwp/celery/utils/log.pytsP                   3U