o ¶Ïiƒã@s–ddlmZddlmZddlZddlZddlZddlZdadada Gdd„dej ƒZdd„Zdd „Z dd ededefdd„ZgZdd„Zdd„ZdS)é)Údeque)ÚdatetimeNcs<eZdZ‡fdd„Z‡fdd„Z‡fdd„Zdd„Z‡ZS) ÚLogInterceptorcsL|j}|j}tƒj|g|¢Ri|¤||jdœ¤Žt ¡|_g|_g|_ dS)N)ÚencodingÚline_buffering) ÚbufferrÚsuperÚ__init__rÚ threadingÚLockÚ_lockÚ_flush_callbacksÚ_logs_since_flush)ÚselfÚstreamÚargsÚkwargsrr©Ú __class__©ú(/mnt/c/Users/fbmor/ComfyUI/app/logger.pyr s& zLogInterceptor.__init__csŒt ¡ ¡|dœ}|j*|j |¡t|tƒr*| d¡r*t dd d¡s*t ¡t |¡Wdƒn1s9wYtƒ |¡dS)N)ÚtÚmú éÿÿÿÿrÚ )rÚnowÚ isoformatrrÚappendÚ isinstanceÚstrÚ startswithÚlogsÚendswithÚpoprÚwrite)rÚdataÚentryrrrr%s&ùzLogInterceptor.writecs*tƒ ¡|jD] }||jƒg|_qdS©N)rÚflushr r)rÚcbrrrr)"s þzLogInterceptor.flushcCs|j |¡dSr()r r)rÚcallbackrrrÚon_flush(szLogInterceptor.on_flush)Ú__name__Ú __module__Ú__qualname__r r%r)r,Ú __classcell__rrrrr s rcCstSr()r"rrrrÚget_logs,sr1cCs,tdur t |¡tdurt |¡dSdSr()Ústdout_interceptorr,Ústderr_interceptor)r+rrrr,0s ÿr,ÚINFOé,FÚ log_levelÚcapacityÚ use_stdoutcCs°trdSt|dattjƒat_ttjƒat_t ¡}| |¡t ¡}| t d¡¡|rQ| dd„¡t tj¡}| t d¡¡| dd„¡| |¡| |¡dS)N)Úmaxlenz%(message)scSs|jtjkSr(©ÚlevelnoÚloggingÚERROR©ÚrecordrrrÚLszsetup_logger..cSs|jtjkSr(r:r>rrrr@Qs)r"rrÚsysÚstdoutr2Ústderrr3r<Ú getLoggerÚsetLevelÚ StreamHandlerÚsetFormatterÚ FormatterÚ addFilterÚ addHandler)r6r7r8ÚloggerÚstream_handlerÚstdout_handlerrrrÚsetup_logger6s rNcCst |¡t |¡dSr()r<ÚwarningÚSTARTUP_WARNINGSr)ÚmsgrrrÚlog_startup_warningZs rRcCs tD]}t |¡qt ¡dSr()rPr<rOÚclear)ÚsrrrÚprint_startup_warnings_srU)r4r5F)ÚcollectionsrrÚior<rAr r"r2r3Ú TextIOWrapperrr1r,r ÚintÚboolrNrPrRrUrrrrÚs !