Ë
    ³ŒjÅ	  ã                   óä   — d dl Z d dlZd dlmZ d dlmZ 	 d dlmZ dZ	 e ej                  d«      xs d«      Z ej                  d	«      Ze� ee«      ndZd
Z G d„ d«      Zy# e
$ r dZ	Y ŒPw xY w)é    N)ÚOptional)Úutils)ÚZstdCompressorTFÚRUN_COMPRESSION_LEVELé   ÚRUN_COMPRESSION_THREADSi   @c                   ó,   — e Zd Zddee   ddfd„Zdd„Zy)ÚCompressedTracesNÚmax_uncompressed_size_bytesÚreturnc                 ó‚  — t         st        d«      ‚|€)t        j                  d«      }|�t	        |«      }nt
        }|| _        t        j                  «       | _	        d| _
        t        j                  «       | _        d| _        g | _        t!        t"        t$        ¬«      j'                  | j                  d¬«      | _        y )Nz¼zstandard is required for compressed trace ingestion. Install it with `pip install zstandard` or set the environment variable LANGSMITH_DISABLE_RUN_COMPRESSION=true to disable compression.ÚMAX_INGEST_MEMORY_BYTESr   ©ÚlevelÚthreadsF©Úclosefd)ÚZSTD_AVAILABLEÚImportErrorÚls_utilsÚget_env_varÚintÚ$DEFAULT_MAX_UNCOMPRESSED_QUEUE_BYTESr   ÚioÚBytesIOÚbufferÚtrace_countÚ	threadingÚLockÚlockÚuncompressed_sizeÚ_contextr   Úcompression_levelÚcompression_threadsÚstream_writerÚcompressor_writer)Úselfr   Úmax_bytes_strs      úp/var/www/html/Fitness-lenito-AI-main/venv/lib/python3.12/site-packages/langsmith/_internal/_compressed_traces.pyÚ__init__zCompressedTraces.__init__   s©   € ÝÜðóð ð 'Ð.Ü$×0Ñ0Ð1JÓKˆMØÐ(Ü.1°-Ó.@Ñ+ä.RÐ+à+FˆÔ(ä"$§*¡*£,ˆŒØ !ˆÔÜ—N‘NÓ$ˆŒ	Ø&'ˆÔØ#%ˆŒä!/Ü#Ô-@ô"
ç
‰-˜Ÿ™¨Uˆ-Ó
3ð 	Õó    c                 óÊ   — t        j                  «       | _        d| _        d| _        g | _        t        t        t        ¬«      j                  | j                  d¬«      | _
        y )Nr   r   Fr   )r   r   r   r   r!   r"   r   r#   r$   r%   r&   )r'   s    r)   ÚresetzCompressedTraces.reset9   sN   € Ü—j‘j“lˆŒØˆÔØ!"ˆÔØˆŒÜ!/Ü#Ô-@ô"
ç
‰-˜Ÿ™¨Uˆ-Ó
3ð 	Õr+   )N)r   N)Ú__name__Ú
__module__Ú__qualname__r   r   r*   r-   © r+   r)   r
   r
      s   „ ñ4°H¸S±Mð 4ÈTó 4ô84r+   r
   )r   r   Útypingr   Ú	langsmithr   r   Ú	zstandardr   r   r   r   r   r#   Ú_compression_threads_envr$   r   r
   r1   r+   r)   Ú<module>r6      s’   ðÛ 	Û Ý å 'ðÝ(à€Nñ Ð,˜×,Ñ,Ð-DÓEÒJÈÓKÐ ð 0˜8×/Ñ/Ð0IÓJÐ à%=Ð%I�CÐ Ô!Èqð ð (:Ð $÷$4ò $4øð# ò Ø‚Nðús   –A% Á%A/Á.A/