§
    ˜Štj§  ã                   ó¶   — d dl Z d dlZd dlZd dlZd dlZd dlmZ d dlm	Z	m
Z
 d dlmZ d dlmZmZ d dlmZ d dlmZ dZd	Z e¦   «         d
eddfd„¦   «         ZdS )é    N)Ú	ClientAPI)ÚSealLogRequestÚMigrateLogRequest)ÚLogServiceStub)ÚresetÚskip_if_not_cluster)Ú
invariants)Úwait_for_version_increasei€„ éd   ÚclientÚreturnc           	      ó  — t          j         ¦   «         }t          j        |¦  «         t          d|¦  «         t	          | ¦  «         |                      dddddœ¬¦  «        }t          j        d¦  «         t          d|j        ¦  «         d}t          d	t          t          ¦  «        D ]Ê}g }g }|                     d
„ t          ||t          z   ¦  «        D ¦   «         ¦  «         |                     d„ t          ||t          z   ¦  «        D ¦   «         ¦  «         	 |                     ||¬¦  «         Œ‰# t          $ r5}t          d|› �¦  «         dt          |¦  «        v rd}Y d }~ nY d }~ŒÃd }~ww xY w|s
J d¦   «         ‚d S )NzGenerating data with seed Útesté€   )zhnsw:construction_efzhnsw:search_efzhnsw:M)ÚnameÚmetadataé   zbackpressuring forFr   c                 ó,   — g | ]}t          |¦  «        ‘ŒS © )Ústr©Ú.0Úxs     úm/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/chromadb/test/distributed/test_log_backpressure.pyú
<listcomp>z)test_log_backpressure.<locals>.<listcomp>-   s   € Ð=Ð=Ð=˜q•C˜‘F”FÐ=Ð=Ð=ó    c                 óZ   — g | ](}t           j                             d d¦  «        d         ‘Œ)S )r   é   r   )ÚnpÚrandomÚrandr   s     r   r   z)test_log_backpressure.<locals>.<listcomp>.   s-   € ÐUÐUÐU°q�2œ9Ÿ>š>¨!¨QÑ/Ô/°Ô2ÐUÐUÐUr   )ÚidsÚ
embeddingszCaught exception:
zYlog needs compaction before accepting more writes; please backoff exponentially and retryTz#Expected an exception to be thrown.)Útimer    ÚseedÚprintr   Úcreate_collectionÚsleepÚidÚrangeÚRECORDSÚ
BATCH_SIZEÚextendÚaddÚ	Exceptionr   )r   r%   Ú
collectionÚexceptedÚir"   r#   r   s           r   Útest_log_backpressurer3      s»  € õ Œ9‰;Œ;€DÝ
„K�ÑÔÐÝ	Ð
&¨Ñ-Ô-Ð-Ý	ˆ&�M„M€MØ×)Ò)ØØ*-ÀÐPSÐTÐTð *ñ ô €Jõ
 	„Jˆq�M„M€Må	Ð
 
¤Ñ.Ô.Ð.à€Hå�1•g�zÑ*Ô*ð ð ˆØˆØˆ
Ø�
Š
Ð=Ð=¥E¨!¨Qµ©^Ñ$<Ô$<Ð=Ñ=Ô=Ñ>Ô>Ð>Ø×ÒÐUÐU½EÀ!ÀQÍÁ^Ñ<TÔ<TÐUÑUÔUÑVÔVÐVð	Ø�NŠN˜s¨zˆNÑ:Ô:Ð:Ð:øÝð 	ð 	ð 	ÝÐ+¨Ð+Ð+Ñ,Ô,Ð,ØjÕnqÐrsÑntÔntÐtÐtØ�Ø�����ð uÐtÐtÐtÐtøøøøð	øøøð
 Ð:Ð:Ð:Ñ:Ô:ˆ8Ð:Ð:s   ÄD1Ä1
E0Ä;%E+Å+E0)ÚgrpcÚmathr    r$   Únumpyr   Úchromadb.apir   Úchromadb.proto.logservice_pb2r   r   Ú"chromadb.proto.logservice_pb2_grpcr   Úchromadb.test.conftestr   r   Úchromadb.test.propertyr	   Ú-chromadb.test.utils.wait_for_version_increaser
   r+   r,   r3   r   r   r   ú<module>r=      s  ðð €€€Ø €€€Ø €€€Ø €€€à Ð Ð Ð à "Ð "Ð "Ð "Ð "Ð "Ø KÐ KÐ KÐ KÐ KÐ KÐ KÐ KØ =Ð =Ð =Ð =Ð =Ð =ðð ð ð ð ð ð ð ð .Ð -Ð -Ð -Ð -Ð -Ø SÐ SÐ SÐ SÐ SÐ Sà
€Ø€
àÐÑÔð;Øð;à	ð;ð ;ð ;ñ Ôð;ð ;ð ;r   