j UddlZddlZddlmZmZmZmZddlmZdZ dZ dZ e a eeed<Gd d ej Zdd Zdej&fd edej(dededed ef dZded edej(deded df dZy)N)AnyCallableOptionalSet)configzOPIK: %(message)sz%(asctime)s [%(process)d-%(processName)s:%(thread)d] %(relativeCreated)d OPIK %(levelname)s [%(filename)s:%(lineno)d]: %(message)siLOG_ONCE_CACHEc deZdZdefdedeededdffd Zdejdeffd Z xZ S) TruncateFormatterNfmtdatefmt max_lengthreturnc4t|||||_yN)super__init__r)selfr r r __class__s f/Users/manta/Documents/Projects/TheRoad-I1/backend/.venv/lib/python3.12/site-packages/opik/_logging.pyrzTruncateFormatter.__init__s g&$recordczt||}t||jkDr|d|jdz}|S)Nz... (truncated).)rformatlenr)rrresultrs rrzTruncateFormatter.formats=' v; (-doo.1CCF r) __name__ __module__ __qualname__MAX_MESSAGE_LENGTHstrrintrlogging LogRecordr __classcell__)rs@rr r sX"&, % %#% %  %W..3rr rctjd}d|_tj}tj }|j }|j||dk(rtnt}|jt||j||j}|jtj|j }|j}|j||jtt|j|t#||j}|j|y)NopikFDEBUG)level)r# getLogger propagater OpikConfig StreamHandlerconsole_logging_levelsetLevelDEBUG_MSG_FORMATCONSOLE_MSG_FORMAT setFormatterr addHandlerr)file_logging_level FileHandler logging_filemin)opik_root_loggerconfig_console_handler console_levelmessage_format root_level file_handler file_levels rsetupr@#s((0!&!G++-O11M]+)W4:L  !2>!BC0 &&J!!-**7+?+?@ // j)!!"34D"EF##L1\%7%78 J/rmessageloggerreturn_on_exception logging_level log_kwargsc <dtdtffd }|S)Nfunctionrcttjdtdtdtffd }|S)Nargskwargsrc` |i|S#t$rjficYSwxYwr) Exceptionlog)rIrJrGrErBrDrArCs rwrapperzDconvert_exception_to_log_message..decorator..wrapperHsB +000 + ='@Z@** +s  --) functoolswrapsr)rGrNrErBrDrArCs` r decoratorz3convert_exception_to_log_message..decoratorGs?  " +3 +# +# + + # +r)rr)rArBrCrDrErQs````` r convert_exception_to_log_messagerR@s# H    rrIrJc|tvr-tj||j||g|i|y|j|g|i|y)z Log the given message once at the given level then at the DEBUG level on further calls. This is a global log-once-per-session N)r addrMdebug)rDrArBrIrJs rlog_once_at_levelrVUsLn$7# =';D;F; W.t.v.r)rN)rOr#typingrrrrrr1r0r setr r!__annotations__ Formatterr r@ERRORLoggerr"rRrVrrr_s//(X!5C ))&0@ $    NN     *// / NN/  /  /  /r