
    i:                    z    U d dl mZ d dlmZ ddlmZ  edd          Zded	<   ddZddZ	 G d d          Z
dS )    )annotations)
ContextVar   )typesinngest_logging_enabledF)defaultzContextVar[bool]_logging_enabledreturnNonec                 :    t                               d           d S )NTr	   set     R/root/projects/qq-shell/venv/lib/python3.11/site-packages/inngest/_internal/log.pyenable_loggingr      s    r   c                 :    t                               d           d S )NFr   r   r   r   disable_loggingr      s    r   c                  &    e Zd ZdZdZddZddZdS )FilteredLoggerz
    Wrapper that intercepts logging calls to prevent duplicates during step replay.
    Uses ContextVar for async/thread safety.
    )	criticaldebugerror	exceptionfatalinfologwarnwarningloggertypes.Loggerr
   r   c                    || _         d S N)_logger)selfr    s     r   __init__zFilteredLogger.__init__'   s    r   namestrobjectc                v    || j         v rt                                          sd S t          | j        |          S )Nc                     d S r#   r   )argskwargss     r   <lambda>z,FilteredLogger.__getattr__.<locals>.<lambda>-   s    4 r   )_proxied_methodsr	   getgetattrr$   )r%   r'   s     r   __getattr__zFilteredLogger.__getattr__*   s=    4(((1A1E1E1G1G(///t|T***r   N)r    r!   r
   r   )r'   r(   r
   r)   )__name__
__module____qualname____doc__r/   r&   r2   r   r   r   r   r      sN         

   + + + + + +r   r   N)r
   r   )
__future__r   contextvarsr    r   r	   __annotations__r   r   r   r   r   r   <module>r;      s    " " " " " " " " " " " " "       &0Zu& & &     
          + + + + + + + + + +r   