
    3i_                         S SK r S SKrS SKrS SKrS SKrS SKJr  S SKJ	r	J
r
  S SKJr  S SKJrJr  S SKJr  S SKJr  SrS	r\" 5       S
\SS4S j5       rg)    N)	ClientAPI)SealLogRequestMigrateLogRequest)LogServiceStub)resetskip_if_not_cluster)
invariants)wait_for_version_increasei d   clientreturnc           
      4   [         R                   " 5       n[        R                  " U5        [        SU5        [	        U 5        U R                  SSSSS.S9n[         R                  " S5        [        SUR                  5        Sn[        S	[        [        5       H  n/ n/ nUR                  [        XD[        -   5       Vs/ s H  n[        U5      PM     sn5        UR                  [        XD[        -   5       Vs/ s H&  n[        R                  R                  SS
5      S	   PM(     sn5         UR                  XVS9  M     U(       d   S5       eg s  snf s  snf ! [          a1  n[        SU 35        S[        U5      ;   a	  Sn S nA  MI   S nAM  S nAff = f)NzGenerating data with seed test   )zhnsw:construction_efzhnsw:search_efzhnsw:M)namemetadata   zbackpressuring forFr      )ids
embeddingszCaught exception:
zBackoff 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           i/home/james-whalen/.local/lib/python3.13/site-packages/chromadb/test/distributed/test_log_backpressure.pytest_log_backpressurer,      sZ    99;D
KK	
&-	&M))*-PST * J
 	JJqM	

.H1gz*


E!^$<=$<qCF$<=>E!^<TU<Tq299>>!Q/2<TUV	NNsN: + :::8 >U  	's+,"c!f, -	s$    E
;-E
0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   