Ë
    lQêj§  ã                   ó¨   — 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y)é    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	        | «       | j                  dddddœ¬«      }t        j                  d«       t        d|j                  «       d}t        d	t        t        «      D ]¤  }g }g }|j                  t        ||t        z   «      D �cg c]  }t        |«      ‘Œ c}«       |j                  t        ||t        z   «      D �cg c]%  }t        j                  j                  dd
«      d	   ‘Œ' c}«       	 |j                  ||¬«       Œ¦ |sJ d«       ‚y c c}w c c}w # t         $ r-}t        d|› �«       dt        |«      v rd}Y d }~ Œ@Y d }~Œìd }~ww xY w)NzGenerating data with seed Útesté€   )zhnsw:construction_efzhnsw:search_efzhnsw:M)ÚnameÚmetadataé   zbackpressuring forFr   é   )ÚidsÚ
embeddingszCaught exception:
zYlog needs compaction before accepting more writes; please backoff exponentially and retryTz#Expected an exception to be thrown.)ÚtimeÚrandomÚseedÚprintr   Úcreate_collectionÚsleepÚidÚrangeÚRECORDSÚ
BATCH_SIZEÚextendÚstrÚnpÚrandÚaddÚ	Exception)r   r   Ú
collectionÚexceptedÚir   r   Úxs           út/home/oem/CyberBrain26-unified/.venv/lib/python3.12/site-packages/chromadb/test/distributed/test_log_backpressure.pyÚtest_log_backpressurer,      s]  € ô �9‰9‹;€DÜ
‡K�K�ÔÜ	Ð
&¨Ô-Ü	ˆ&„MØ×)Ñ)ØØ*-ÀÐPSÑTð *ó €Jô
 	‡J�Jˆq„Mä	Ð
 
§¡Ô.à€Hä�1”gœzÓ*ò ˆØˆØˆ
Ø�
‰
¤E¨!¨Q´©^Ó$<Ö=˜q”C˜•FÒ=Ô>Ø×Ñ¼EÀ!ÀQÌÁ^Ó<TÖU°qœ2Ÿ9™9Ÿ>™>¨!¨QÓ/°Ó2ÒUÔVð	Ø�N‰N˜s¨zˆNÕ:ðñ Ð:Ð:Ó:‰8ùò >ùÚUøô ò 	ÜÐ'¨ sÐ+Ô,ØjÔnqÐrsÓntÑtØ�Ýô uûð	ús$   ÃE
Ã:*E
Ä,EÅ	FÅFÆF)Ú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    r,   © ó    r+   ú<module>r8      s[   ðó Û Û Û ã å "ß KÝ =÷õ .Ý Sà
€Ø€
áÓð;Øð;à	ò;ó ñ;r7   