
    LKi,	                         S SK Jr  S SKrS SKJr  S SKJrJr  S SKJ	r	  \	S\SS4S j5       r
S\SS4S	 jrS\SS4S
 jrg)    )ThreadPoolExecutorN)	ClientAPI)ChromaErrorUniqueConstraintError)multi_region_testclientreturnc                 &   U R                  5         U R                  SSSSS.S9   U R                  SSSSS.S9   S5       e! [         aE  n[        SU5        SUR                  S   ;   d  [        U[        5      (       d   e S nAg  S nAg S nAff = f)	Ntest   )zhnsw:construction_efzhnsw:search_efzhnsw:M)namemetadataExpected exceptionz2Collection creation failed as expected with error zalready existsr   )resetcreate_collection	Exceptionprintargs
isinstancer   r   es     c/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/test/api/test_collection.py test_duplicate_collection_creater      s     LLN
*-PST  
U  (+"% 	! 	
 	+**u UBAF166!9,
1>S0T0TTT0T,Us   A 
B6BBc                      U R                  SS9   S5       e! [         a+  n[        SU5        SUR                  S   ;   d   e S nAg S nAff = f)Ntest101)r   r   z2Collection deletion failed as expected with error does not existr   )delete_collectionr   r   r   r   s     r   #test_not_existing_collection_deleter   "   s[    -   	! 	
 	+**u -BAF166!9,,,-s    
A!AAc                 x  ^ ^ Sn[        [        R                  " 5       5      mS[        SS 4U U4S jjn[	        US9 n[        U5       Vs/ s H  oCR                  X$5      PM     nnU H  n UR                  5         M     S S S 5        g s  snf ! [         a  n SU 35       eS nAff = f! , (       d  f       g = f)N2   ir	   c                 <  >  TR                  T5      nUR                  T:X  d   e  U S-  S:X  a  TR	                  T5        g g ! [         a   nSUR                  5       ;  a  Ue S nANBS nAff = f! [         a   nSUR                  5       ;  a  Ue S nAg S nAff = f)N
concurrent   r   r   )get_or_create_collectionr   r   messager   )r!   collr   r   new_names      r   create_maybe_delete_collectionHtest_multithreaded_get_or_create.<locals>.create_maybe_delete_collection4   s    	228<D99(((
	1uz((2   	199;. /	  	qyy{2 3	s.   #A A1 
A.A))A.1
B;BB)max_workerszThread raised an exception: )	struuiduuid4intr   rangesubmitresultr   )	r   	N_THREADSr)   executorr!   futuresfuturer   r(   s	   `       @r    test_multithreaded_get_or_creater7   0   s    I4::< H# $    
		2hHMiHX
HX1OO:>HX 	 
 FA 	 
3	2
  A@ <QC@@uA 
3	2sA   B+B
%B+-B=B+
B+
B(
B##B((B++
B9)concurrent.futuresr   r-   chromadb.apir   chromadb.errorsr   r   chromadb.test.conftestr   r   r   r7        r   <module>r>      sg    1  " > 4 UU	U U2
-
-	
-AY A4 Ar=   