
    LKi	                     j    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r\" 5       S\SS4S j5       rg)	    )Sequence)resetskip_if_not_cluster)	ClientAPI)clientconfigNr   returnc                    [        U 5        U R                  SSSSS.S9n[        S5       Vs/ s H  n[        U5      PM     nn[        S5       Vs/ s H#  n[	        U5      [	        U5      [	        U5      /PM%     nnUR                  X4S9  UR                  US   /S9  [        R                  " 5         [        R                  " 5       nUR                  S	S
S9n[        UR                  5      S:  d   eUR                  n[        5       nU He  n	UR                  U	R                  R                   5        U	R                  R"                  n
U	R                  R$                  nUR'                  X5        Mg     Sn[(        R(                  " 5       n UR                  S	S
S9nUR                  n[        U V	s/ s H  oR                  R                   PM     sn	5      n[        U5      [        U5      :X  a  [        UR+                  U5      5      S:X  a  O;[(        R(                  " 5       U-
  U:  a   S5       e[(        R,                  " S5        M   UR                  S	S
S9nUR                  nSnU H!  n	U	R.                  R0                  S:w  d  M  Sn  O   U(       a  O;[(        R(                  " 5       U-
  U:  a   S5       e[(        R,                  " S5        M  [(        R,                  " S5        UR                  US   /S9  g s  snf s  snf s  sn	f )Ntest   )zhnsw:construction_efzhnsw:search_efzhnsw:M)namemetadata
   )ids
embeddingsr   )query_embeddingschromazapp=query-service)label_selectorTFz'Timed out waiting for new pods to start   Runningz*Timed out waiting for new pods to be ready)r   create_collectionrangestrfloataddqueryr   load_kube_config
k8s_client	CoreV1Apilist_namespaced_podlenitemssetr   uidr   	namespacedelete_namespaced_podtimeintersectionsleepstatusphase)r   
collectionir   r   v1resr"   seen_idsitemr   r%   timeout_secs
start_timenew_idsreadys                   h/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/test/distributed/test_reroute.pytest_rerouter7      s    
&M))*-PST * J
 !9
%9a3q69C
%05b	)091q58U1X&	  ) NNsN2z!}o6 				B

 
 :M
 
NCsyy>AIIEuH T]]&&'}}!!MM++	
  1	  LJ
$$X>Q$R		U;UT}}((U;<w<3x=(S1E1Eh1O-PTU-U99;#l2CCC5

1  $$X>Q$R		D{{  I-  99;#l2FFF5

1  	JJqMz!}o6k &): <s   K=*L2L)typingr   chromadb.test.conftestr   r   chromadb.apir   
kubernetesr   r   r   r'   r7        r6   <module>r>      s?     # 3  >7>7	>7 >7r=   