RǻiddlmZddlZddlmZddlm Z m Z m ZmZmZmZmZmZmZddlmZddlmZ dd gZ!Gd d eZ"Gd d eZ#GddZ$e edddd ddZ%y)) annotationsN)suppress) CRITICALDEBUGERRORFilter Formatter getLoggerINFO StreamHandlerWARNING)stderr)_typingWatcherwatchc"eZdZdZfdZxZS)_ColourFormatterz'Colour formatter for pretty log output.c t||}|jtk(rd|dS|jtk(rd|dS|jt k(rd|dS|jt k(rd|dS|jtk(rd|dS|S)Nzzzzzz)superformatlevelno _CRITICAL_ERROR_WARNING_INFO_DEBUG)selfrecords __class__s I/opt/lhia/marcimex/agent/venv/lib/python3.12/site-packages/neo4j/debug.pyrz_ColourFormatter.format/s GN6 " >>Y &s'* * ^^v %s'* * ^^x 'aS( ( ^^u $aS( ( ^^v %aS( (H)__name__ __module__ __qualname____doc__r __classcell__r!s@r"rr,s1  r#rceZdZdZdZy) _TaskIdFilterz)Injecting async task id into log records.cv ttj|_y#t$r d|_YywxYw)NT)id_asyncio current_tasktask RuntimeError)rrs r"filterz_TaskIdFilter.filterBs< X2245FK FK s "%88N)r$r%r&r'r2r#r"r+r+?s 3r#r+cxeZdZdZeedddd d fdZd dZdZ d d dZ dd Z xZ S)ra8 Log watcher for easier logging setup. Example:: from neo4j.debug import Watcher with Watcher("neo4j"): # DEBUG logging to stderr enabled within this context ... # do something .. note:: The Watcher class is not thread-safe. Having Watchers in multiple threads can lead to duplicate log messages as the context manager will enable logging for all threads. .. note:: The exact logging format and messages are not part of the API contract and might change at any time without notice. They are meant for debugging purposes and human consumption only. :param logger_names: Names of loggers to watch. :param default_level: Default minimum log level to show. The level can be overridden by setting ``level`` when calling :meth:`.watch`. :param default_out: Default output stream for all loggers. The level can be overridden by setting ``out`` when calling :meth:`.watch`. :type default_out: stream or file-like object :param colour: Whether the log levels should be indicated with ANSI colour codes. :param thread_info: whether to include information about the current thread in the log message. Defaults to :data:`True`. :param task_info: whether to include information about the current async task in the log message. Defaults to :data:`True`. .. versionchanged:: 5.3 * Added ``thread_info`` and ``task_info`` parameters. * Logging format around thread and task information changed. FT default_level default_outcolour thread_info task_infoc&t |||_|jDcgc] }t|c}|_||_||_i|_||_d}|rd|z}|rd|z}|sd|z}|rtnt} | ||_ ycc}w)Nz%(asctime)s %(message)sz[Task %(task)-15s] z[Thread %(thread)d] z[%(levelname)-8s] ) r__init__ _logger_names _getLogger_loggers_default_level _default_out _handlers _task_infor _Formatter formatter) rr6r7r8r9r: logger_namesnameformat_ formatter_clsr!s r"r<zWatcher.__init__ts )6:6H6HIdD)I +'46#, +g5G ,w6G*W4G,2( &w/JsBc&|j|S)zEnable logging for all loggers.)r)rs r" __enter__zWatcher.__enter__s  r#c$|jyz Disable logging for all loggers.N)stop)rexc_typeexc_valexc_tbs r"__exit__zWatcher.__exit__s  r#c| |j}| |j}|jt|}|j |j |j ||jr|jt|jD]Q}||j|j<|j||j|kDsA|j |Sy)a: Enable logging for all loggers. :param level: Minimum log level to show. If :data:`None`, the ``default_level`` is used. :param out: Output stream for all loggers. If :data:`None`, the ``default_out`` is used. :type out: stream or file-like object N)r@rArN_StreamHandler setFormatterrEsetLevelrC addFilterr+r?rBrG addHandlergetEffectiveLevel)rlevelouthandlerloggers r"rz Watcher.watchs =''E ;##C  %T^^, ??   mo .mm 'F*1DNN6;; '   g &'')E1&  'r#c|jD]N}tt5|j|jj |j dddPy#1swY[xYwrM)r? _suppressKeyError removeHandlerrBpoprG)rr]s r"rNz Watcher.stops_mm FF8$ F$$T^^%7%7 %DE F F F F Fs 5AA( )rF str | Noner6intr7 _t.TextIOr8boolr9rfr:rfreturnNone)rgr)NN)rZz int | Noner[z_t.TextIO | Nonergrh)rgrh) r$r%r&r'r_stderrr<rKrRrrNr(r)s@r"rrJs'X$!( 0!00 0  0  00 06  AE''-=' '8Fr#FT)rZr[r8r9r:c Dt||||||d}|j|S)aC Quick wrapper for using :class:`.Watcher`. Create a Watcher with the given configuration, enable watching and return it. Example:: from neo4j.debug import watch watch("neo4j") # from now on, DEBUG logging to stderr is enabled in the driver .. note:: The exact logging format and messages are not part of the API contract and might change at any time without notice. They are meant for debugging purposes and human consumption only. :param logger_names: Names of loggers to watch. :param level: see ``default_level`` of :class:`.Watcher`. :param out: see ``default_out`` of :class:`.Watcher`. :param colour: see ``colour`` of :class:`.Watcher`. :param thread_info: see ``thread_info`` of :class:`.Watcher`. :param task_info: see ``task_info`` of :class:`.Watcher`. :returns: Watcher instance :rtype: :class:`.Watcher` .. versionchanged:: 5.3 * Added ``thread_info`` and ``task_info`` parameters. * Logging format around thread and task information changed. r5)rr)rZr[r8r9r:rFwatchers r"rrs1R  G MMO Nr#)rFrcrZrdr[rer8rfr9rfr:rfrgr)& __future__r_asyncior. contextlibrr_loggingrrrrrrr_Filterr rDr r>r rr rTr rsysrrir_t__all__rr+rrr3r#r"rvs"(,   "   z&GnFnFf 22 2 2  2  2  2 2r#