
    LKih                        S SK r S SKJr  S SKrS SKrS SKJrJrJ	r	J
r
JrJrJrJr  S SKrS SKrS SKJr  S SKJr  S SKJr  S SKJr  S SKJr  S S	KJrJrJrJr  S S
K J!r!J"r"J#r#J$r$  S SK%J&r&J'r'J(r(  S SK)J*r*  S SK+J,r,  S SK-J.r.J/r/J0r1  S SK2J3r3  S SK4J5r5J6r6J7r7J8r8J9r9J:r:J;r;J<r<J=r=J>r>J?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrGJHrH  S SK4JIrIJJrJJKrK  \R                  " \M5      rN " S S\\5      rOg)    N)UUID)AnyMappingOptionalcastTupleSequenceDictList)override)__version__)UserIdentity)AsyncServerAPI)BaseHTTPClient)CreateCollectionConfigurationUpdateCollectionConfiguration'create_collection_configuration_to_json'update_collection_configuration_to_json)DEFAULT_DATABASEDEFAULT_TENANTSystemSettings)OpenTelemetryClientOpenTelemetryGranularitytrace_method)ProductTelemetryClient)async_to_sync)DatabaseTenant
Collection)Search)	Documents
EmbeddingsIDsIncludeIndexingStatusSchema	Metadatas	ReadLevelURIsWhereWhereDocument	GetResultQueryResultSearchResultCollectionMetadata%optional_embeddings_to_base64_stringsvalidate_batchconvert_np_embeddings_to_listIncludeMetadataDocuments!IncludeMetadataDocumentsDistances)"IncludeMetadataDocumentsEmbeddingsserialize_metadatadeserialize_metadatac                   n  ^  \ rS rSr% 0 r\\\R                  4   \	S'   S\
4U 4S jjrSvS jrSwS jrS	\S
\S\SS4S jr\SwU 4S jj5       rS\R                  4S jr\S\\\4   4S j5       r\S\4S j5       rS\S\S\\\4   S\4S jr\" S\R4                  5      \S\4S j5       5       r\" S\R4                  5      \\4S\S\SS4S jj5       5       r\" S\R4                  5      \\4S\S\S\4S jj5       5       r\" S\R4                  5      \\4S\S\SS4S jj5       5       r \" S\R4                  5      \SS\4S \!\   S!\!\   S\S\"\   4S" jj5       5       r#\" S#\R4                  5      \S\SS4S$ j5       5       r$\" S%\R4                  5      \S\S\%4S& j5       5       r&\" S'\R4                  5      \S\'4S( j5       5       r(\" S)\R4                  5      \SS\\)4S \!\   S!\!\   S\S*\S\"\*   4
S+ jj5       5       r+\" S,\R4                  5      \\\)4S\S*\S\4S- jj5       5       r,\" S.\R4                  5      \SSSS/\\)4S\S0\!\-   S1\!\.   S2\!\/   S3\0S\S*\S\*4S4 jj5       5       r1\" S5\R4                  5      \\\)4S\S\S*\S\*4S6 jj5       5       r2\" S7\R4                  5      \SSS\\)4S\S0\!\-   S1\!\.   S2\!\/   S\S*\S\*4S8 jj5       5       r3\" S9\R4                  5      \SSS\\)4S:\4S;\!\   S<\!\/   S=\!\5   S\S*\SS4S> jj5       5       r6\" S?\R4                  5      \\\)4S@\4S;\S\S*\S\*4
SA jj5       5       r7\" SB\R4                  5      \\\)4S@\4S\S*\S\84SC jj5       5       r9\" SD\R4                  5      \\\)\:Rv                  4S@\4SE\<\=   S\S*\SF\:S\>4SG jj5       5       r?\" SH\R4                  5      \\\)4S\S\S*\SS4SI jj5       5       r@\" SJ\R4                  5      \\\)4S@\4S\S*\S\4SK jj5       5       rA\" SL\R4                  5      \SM\\)4S@\4SN\S\S*\S\B4
SO jj5       5       rC\" SP\R4                  5      \SSSSS\D\\)4S@\4SQ\!\E   SR\!\F   S \!\   S!\!\   SS\!\G   ST\HS\S*\S\B4SU jj5       5       rI\" SV\R4                  5      \SSS\\)4S@\4SQ\!\E   SR\!\F   SS\!\G   S\S*\SS4SW jj5       5       rJ\" SX\R                  5      SY\L\E\!\M   \!\N   \!\O   \!\P   4   SZ\S\4S[ j5       rQ\" S\\R                  5      \SSS\\)4SQ\ES@\4S]\MS^\!\N   S_\!\O   S`\!\P   S\S*\S\04Sa jj5       5       rR\" Sb\R                  5      \SSSS\\)4S@\4SQ\ES]\!\M   S^\!\N   S_\!\O   S`\!\P   S\S*\S\04Sc jj5       5       rS\" Sd\R                  5      \SSS\\)4S@\4SQ\ES]\MS^\!\N   S_\!\O   S`\!\P   S\S*\S\04Se jj5       5       rT\" Sf\R                  5      \SSMSS\U\\)4S@\4Sg\MSQ\!\E   Sh\SR\!\F   SS\!\G   ST\HS\S*\S\V4Si jj5       5       rW\" Sj\R                  5      \S\04Sk j5       5       rX\" Sl\R4                  5      \S\4Sm j5       5       rY\S\Z4Sn j5       r[\" So\R4                  5      S\4Sp j5       r\\" Sq\R4                  5      S\04Sr j5       r]\" Ss\R4                  5      \S\4St j5       5       r^Sur_U =r`$ )xAsyncFastAPI?   _clientssystemc                   > [         TU ]  U5        UR                  R                  S5        UR                  R                  S5        U R                  [        5      U l        U R                  [        5      U l        UR                  U l        [        R                  [        UR                  R                  5      UR                  R                  UR                  R                  UR                  R                  S9U l        g )Nchroma_server_hostchroma_server_http_port)r?   r@   chroma_server_ssl_enableddefault_api_path)super__init__settingsrequirer   _opentelemetry_clientr   _product_telemetry_client	_settingsr:   resolve_urlstrr?   r@   rA   chroma_server_api_default_path_api_url)selfr=   	__class__s     \/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/api/async_fastapi.pyrD   AsyncFastAPI.__init__J   s      45 9:%)\\2E%F")-6L)M&$00"6??#E#EF$*OO$K$K&,oo&O&O#__KK	 1 
    returnc                 .   #    U R                  5         U $ 7fN)_get_clientrN   s    rP   
__aenter__AsyncFastAPI.__aenter__[   s     s   Nc                    #    [        U R                  5      S:  aP  U R                  R                  5       u  pUR                  5       I S h  vN   [        U R                  5      S:  a  MO  g g  N!7f)Nr   )lenr<   popitemaclose)rN   _clients      rP   _cleanupAsyncFastAPI._cleanup_   sO     $-- 1$--//1KQ--/!! $-- 1$!s   A	A/A-A/+A/exc_type	exc_value	tracebackc                 @   #    U R                  5       I S h  vN   g  N7frU   r`   )rN   rb   rc   rd   s       rP   	__aexit__AsyncFastAPI.__aexit__d   s     mmos   c                 T   >^  [         TT ]  5         [        SU 4S jj5       nU" 5         g )Nc                  B   >#    T R                  5       I S h  vN   g  N7frU   rf   rW   s   rP   sync_cleanup'AsyncFastAPI.stop.<locals>.sync_cleanupk   s     --/!!s   rS   N)rC   stopr   )rN   rk   rO   s   ` rP   rn   AsyncFastAPI.stopg   s%    		" 
	" 	rR   c                    S n [         R                  " 5       nUR                  5       nXR                  ;  a  U R
                  R                  =(       d    0 R                  5       nSUS'   S[        -   S-   US'   [        R                  " S UU R
                  R                  =(       d    SU R                  S9U R                  U'   U R                  U   $ ! [         a    Sn Nf = f)	Nr   zapplication/jsonzContent-TypezChroma Python Client vz( (https://github.com/chroma-core/chroma)z
User-AgentF)timeoutheadersverifylimits)asyncioget_event_loop__hash__RuntimeErrorr<   rI   chroma_server_headerscopyr   httpxAsyncClientchroma_server_ssl_verifyhttp_limits)rN   	loop_hashlooprr   s       rP   rV   AsyncFastAPI._get_clientq   s     		))+DI MM)~~;;ArGGIG&8GN#(<= L! (-'8'8~~>>G%''	(DMM)$ }}Y'''  	I	s   %C C"!C"c                 H    [        U R                  5       R                  5      $ rU   )dictrV   rr   rW   s    rP   get_request_headers AsyncFastAPI.get_request_headers   s    D$$&..//rR   c                     U R                   $ rU   )rM   rW   s    rP   get_api_urlAsyncFastAPI.get_api_url   s    }}rR   methodpathkwargsc                   #    SU;   a6  [         R                  " UR                  S5      [         R                  S9nXCS'   [        R
                  R                  USS S S9nU R                  U-   nU R                  5       R                  " X40 [        [        U5      D6I S h  vN n[        R                  " U5        [         R                  " UR                  5      $  N:7f)Njson)optioncontent/)safeencodingerrors)orjsondumpspopOPT_SERIALIZE_NUMPYurllibparsequoterM   rV   requestr   r   r   _raise_chroma_errorloadstext)rN   r   r   r   dataescaped_pathurlresponses           rP   _make_requestAsyncFastAPI._make_request   s      V<<

6 26;U;UVD $9 ||))$S4PT)Umml*))+33FU4VCTUU**84||HMM** Vs   BC C!;CzAsyncFastAPI.heartbeatc                 ^   #    U R                  SS5      I S h  vN n[        US   5      $  N7f)Nget znanosecond heartbeat)r   int)rN   r   s     rP   	heartbeatAsyncFastAPI.heartbeat   s2      ++E26682344 7s   -+-zAsyncFastAPI.create_databasenametenantc                 N   #    U R                  SSU S3SU0S9I S h  vN   g  N7f)Npost	/tenants/
/databasesr   r   r   rN   r   r   s      rP   create_databaseAsyncFastAPI.create_database   s:        xz*$ ! 
 	
 	
s   %#%zAsyncFastAPI.get_databasec                 x   #    U R                  SSU SU 3SU0S9I S h  vN n[        US   US   US   S9$  N7f)	Nr   r   /databases/r   paramsidr   r   r   r   )r   r   )rN   r   r   r   s       rP   get_databaseAsyncFastAPI.get_database   se      ++x{4&1f% , 
 
 ~HV$4Xh=O
 	

s   :8:zAsyncFastAPI.delete_databasec                 P   #    U R                  SSU SU 35      I S h  vN   g  N7f)Ndeleter   r   r   r   s      rP   delete_databaseAsyncFastAPI.delete_database   s2        x{4&1
 	
 	
s   &$&zAsyncFastAPI.list_databaseslimitoffsetc           	         #    U R                  SSU S3[        R                  " UUS.5      S9I S h  vN nU Vs/ s H  n[        US   US   US   S	9PM     sn$  N)s  snf 7f)
Nr   r   r   r   r   r   r   r   r   r   )r   r   _clean_paramsr   )rN   r   r   r   r   dbs         rP   list_databasesAsyncFastAPI.list_databases   s      ++xz*!//"$ , 	
 	
 
 4r&z"X,G
 	
	

s    0A#AA#AA#A#zAsyncFastAPI.create_tenantc                 F   #    U R                  SSSU0S9I S h  vN   g  N7f)Nr   z/tenantsr   r   r   )rN   r   s     rP   create_tenantAsyncFastAPI.create_tenant   s1        $ ! 
 	
 	
s   !!zAsyncFastAPI.get_tenantc                 `   #    U R                  SSU-   5      I S h  vN n[        US   S9$  N7f)Nr   r   r   )r   )r   r   )rN   r   	resp_jsons      rP   
get_tenantAsyncFastAPI.get_tenant   s>      ,,$
 
	
 9V,--
s   .,.zAsyncFastAPI.get_user_identityc                 T   #    [        S0 U R                  SS5      I S h  vN D6$  N7f)Nr   z/auth/identity )r   r   rW   s    rP   get_user_identityAsyncFastAPI.get_user_identity  s)      RT%7%7?O%PPRRPs   (&(zAsyncFastAPI.list_collectionsdatabasec           	         #    U R                  SSU SU S3[        R                  " UUS.5      S9I S h  vN nU Vs/ s H  n[        R                  " U5      PM     nnU$  N,s  snf 7f)Nr   r   r   /collectionsr   r   )r   r   r   CollectionModel	from_json)rN   r   r   r   r   r   json_collectionmodelss           rP   list_collectionsAsyncFastAPI.list_collections
  s      ,,x{8*LA!//"$ - 	
 	
	 OX
NW?O%%o6i 	 
 	

s    3A)A"A) A$A)$A)zAsyncFastAPI.count_collectionsc                 p   #    U R                  SSU SU S35      I S h  vN n[        [        U5      $  N7f)Nr   r   r   z/collections_countr   r   r   )rN   r   r   r   s       rP   count_collectionsAsyncFastAPI.count_collections#  sF     
 ,,x{8*4FG
 
	
 C##
s   646zAsyncFastAPI.create_collectionFschemaconfigurationmetadataget_or_createc           
         #    U(       a  [        X45      OSnU(       a  UR                  5       OSn	U R                  SSU SU S3UUUU	US.S9I Sh  vN n
[        R                  " U
5      nU$  N7f)zCreates a collectionNr   r   r   r   )r   r   r   r   r   r   )r   serialize_to_jsonr   r   r   )rN   r   r   r   r   r   r   r   config_jsonserialized_schemar   models               rP   create_collectionAsyncFastAPI.create_collection/  s       4ML 	
 ;AF446d,,x{8*LA$!,+!. - 

 

	  )))4

s   AA0A.A0zAsyncFastAPI.get_collectionc           	         #    U R                  SSU SU SU 35      I S h  vN n[        R                  " U5      nU$  N7f)Nr   r   r   /collections/r   r   r   )rN   r   r   r   r   r   s         rP   get_collectionAsyncFastAPI.get_collectionQ  sQ      ,,x{8*M$H
 
	
  )))4
s   A >A z%AsyncFastAPI.get_or_create_collectionc           
      H   #    U R                  UUUUSUUS9I S h  vN $  N7f)NT)r   r   r   r   r   r   r   )r   )rN   r   r   r   r   r   r   s          rP   get_or_create_collection%AsyncFastAPI.get_or_create_collectionb  s>      ++' , 
 
 	
 
s   " "zAsyncFastAPI._modifyr   new_namenew_metadatanew_configurationc           	         #    U R                  SSU SU SU 3UUU(       a  [        U5      OS S.S9I S h  vN   g  N7f)Nputr   r   r   )r   r   r   r   )r   r   )rN   r   r   r   r   r   r   s          rP   _modifyAsyncFastAPI._modifyy  s`        x{8*M"F ,$ % &M%&  ! 
 	
 	
s   4><>zAsyncFastAPI._forkcollection_idc           
         #    U R                  SSU SU SU S3SU0S9I S h  vN n[        R                  " U5      nU$  N7f)Nr   r   r   r   z/forkr   r   r   )rN   r   r   r   r   r   r   s          rP   _forkAsyncFastAPI._fork  sa      ,,x{8*M-PUVh' - 
 
	
  )))4
s   !AA Az!AsyncFastAPI._get_indexing_statusc           
         #    U R                  SSU SU SU S35      I S h  vN n[        US   US   US   US	   S
9$  N7f)Nr   r   r   r   z/indexing_statusnum_indexed_opsnum_unindexed_ops	total_opsop_indexing_progress)r  r  r  r  )r   r&   rN   r   r   r   r   s        rP   _get_indexing_status!AsyncFastAPI._get_indexing_status  so      ,,x{8*M-P`a
 
	 %&78'(;<,!*+A!B	
 	
	
s    A?AzAsyncFastAPI._searchsearches
read_levelc           
      r  #    U Vs/ s H  ofR                  5       PM     snUS.nU R                  SSU SU SU S3US9I Sh  vN nUR                  S	S5      n	U	b<  U	 V
Vs/ s H)  n
U
b!  U
 Vs/ s H  nUb  [        U5      OSPM     snOSPM+     snn
US	'   [	        U5      $ s  snf  Nes  snf s  snn
f 7f)
z&Performs hybrid search on a collection)r  r	  r   r   r   r   z/searchr   N	metadatas)to_dictr   r   r8   r/   )rN   r   r  r   r   r	  spayloadr   metadata_batchesr  r   s               rP   _searchAsyncFastAPI._search  s      /77hh7$

 ,,x{8*M-PWX - 
 
	 %==d;' "2& "2I ( %.$- 7?6J(2PTT$-
  "2&Ik" I&&- 8
&s?   B7B%$B7B*B7#B10B,
	B1B7,B11B7zAsyncFastAPI.delete_collectionc           	      V   #    U R                  SSU SU SU 35      I S h  vN   g  N7f)Nr   r   r   r   r   )rN   r   r   r   s       rP   delete_collectionAsyncFastAPI.delete_collection  s8        x{8*M$H
 	
 	
s   )')zAsyncFastAPI._countc           
      v   #    U R                  SSU SU SU S35      I Sh  vN n[        [        U5      $  N7f)z0Returns the number of embeddings in the databaser   r   r   r   z/countNr   r  s        rP   _countAsyncFastAPI._count  sL      ,,x{8*M-PVW
 
	
 C##
s    979zAsyncFastAPI._peek
   nc                 P   #    U R                  UUUU[        S9I S h  vN nU$  N7f)N)r   r   r   include)_getr6   )rN   r   r  r   r   resps         rP   _peekAsyncFastAPI._peek  s:      YY6  
 
 
s   &$&zAsyncFastAPI._getidswherewhere_documentr  c
                   #    U V
s/ s H  oS:w  d  M
  U
PM     nn
U R                  SSU SU	 SU S3UUUUUUS.S9I S h  vN nUR                  S	S 5      nUb   U Vs/ s H  nUb  [        U5      OS PM     nn[        US
   UR                  SS 5      UUR                  SS 5      S UR                  SS 5      US9$ s  sn
f  Ns  snf 7f)Nr   r   r   r   r   z/get)r   r!  r   r   r"  r  r   r  r   
embeddings	documentsuris)r   r$  r  r%  r   r&  included)r   r   r8   r-   )rN   r   r   r!  r   r   r"  r  r   r   ifiltered_includer   r  r   s                  rP   r  AsyncFastAPI._get  s     (/>w!v+Aw>,,x{8*M-PTU "0+ - 
 
	 MM+t4	  !* )H 3;2F$X.DP )  
 %  }}\48mmK6vt,
 	
- ?
s3   C		B=B='C	CC	C9A
C	C	zAsyncFastAPI._deletec           
      \   #    U R                  SSU SU SU S3X2US.S9I S h  vN   g  N7f)Nr   r   r   r   z/delete)r!  r   r"  r   r   )rN   r   r   r!  r"  r   r   s          rP   _deleteAsyncFastAPI._delete;  sR        x{8*M-PWX O ! 
 	
 	

 	
s   ",*,zAsyncFastAPI._submit_batchbatchr   c                 &  #    U R                  5       I Sh  vN nSnUS   b#  US    Vs/ s H  nUb  [        U5      OSPM     nnUS   U(       a  [        US   5      OUS   UUS   US   S.nU R                  SUUS	9I Sh  vN $  Nqs  snf  N7f)
z/
Submits a batch of embeddings to the database
N   r            )r   r$  r  r%  r&  r   r   )supports_base64_encodingr7   r1   r   )rN   r.  r   r4  serialized_metadatasr   r   s          rP   _submit_batchAsyncFastAPI._submit_batchM  s      *.)F)F)H#H #8 !&a$ (H 190D"8,$N ( ! $ 8' @aIq-q!H
 '' ( 
 
 	
' $I$
s,   BBBB
?BBB
BzAsyncFastAPI._addr$  r  r%  r&  c	                    #    UUUUU4n	[        U	SU R                  5       I S h  vN 05        U R                  U	SU SU S[        U5       S35      I S h  vN   g N7 N7f)Nmax_batch_sizer   r   r   z/addTr2   get_max_batch_sizer6  rK   )
rN   r   r   r$  r  r%  r&  r   r   r.  s
             rP   _addAsyncFastAPI._addu  s      
 	u/t7N7N7P1PQR  x{8*M#mBTAUUYZ
 	
 	
  2Q	
!   "A A1A AA A zAsyncFastAPI._updatec	                    #    UUb  UOS UUU4n	[        U	SU R                  5       I S h  vN 05        U R                  U	SU SU S[        U5       S35      I S h  vN   g N7 N7f)Nr9  r   r   r   z/updateTr:  
rN   r   r   r$  r  r%  r&  r   r   r.  s
             rP   _updateAsyncFastAPI._update  s      $0Jd
 	u/t7N7N7P1PQR  x{8*M#mBTAUU\]
 	
 	

  2Q	
s!   'A%A!1A%A#A%#A%zAsyncFastAPI._upsertc	                    #    UUUUU4n	[        U	SU R                  5       I S h  vN 05        U R                  U	SU SU S[        U5       S35      I S h  vN   g N7 N7f)Nr9  r   r   r   z/upsertTr:  r@  s
             rP   _upsertAsyncFastAPI._upsert  s      
 	u/t7N7N7P1PQR  x{8*M#mBTAUU\]
 	
 	
  2Q	
r>  zAsyncFastAPI._queryquery_embeddings	n_resultsc
                   #    U V
s/ s H  oS:w  d  M
  U
PM     nn
U R                  SSU SU	 SU S3UUb  [        U5      OS UUUUS.S9I S h  vN nUR                  S	S 5      nUb8  U VVs/ s H)  nUb!  U Vs/ s H  nUb  [        U5      OS PM     snOS PM+     nnn[	        US
   UR                  SS 5      UR                  SS 5      UUR                  SS 5      UR                  SS 5      S US9$ s  sn
f  Ns  snf s  snnf 7f)Nr   r   r   r   r   z/query)r   rF  rG  r!  r"  r  r   r  r   	distancesr$  r%  r&  )r   rI  r$  r  r%  r&  r   r'  )r   r3   r   r8   r.   )rN   r   rF  r   rG  r!  r"  r  r   r   r(  r)  r   r  r  r   s                   rP   _queryAsyncFastAPI._query  se     (/>w!v+Aw>,,x{8*M-PVW#/ %BBR$S&"0+	 - 
 
	 %==d;' "2  "2I ( %.$- 7?6J(2PTT$-
  "2    % mmK6 }}\48&mmK6vt,	
 		
; ?
$ sE   D	C4C45DC9D.D ;C;	D AD;D  DzAsyncFastAPI.resetc                 b   #    U R                  SS5      I S h  vN n[        [        U5      $  N7f)Nr   z/reset)r   r   boolrN   r   s     rP   resetAsyncFastAPI.reset  s.      ,,VX>>	D)$$ ?   /-/zAsyncFastAPI.get_versionc                 b   #    U R                  SS5      I S h  vN n[        [        U5      $  N7f)Nr   z/version)r   r   rK   rN  s     rP   get_versionAsyncFastAPI.get_version  s/      ,,UJ??	C## @rQ  c                     U R                   $ rU   )rI   rW   s    rP   get_settingsAsyncFastAPI.get_settings  s    ~~rR   z"AsyncFastAPI.get_pre_flight_checksc                    #    U R                   c   U R                  SS5      I S h  vN nXl         U R                   $  N7f)Nr   z/pre-flight-checks)pre_flight_checksr   rN  s     rP   get_pre_flight_checks"AsyncFastAPI.get_pre_flight_checks  sA      !!)"008LMMI%."%%% Ns   #><>z%AsyncFastAPI.supports_base64_encodingc                    #    U R                  5       I S h  vN n[        [        UR                  SS5      5      nU$  N&7f)Nr4  F)rZ  r   rM  r   )rN   rY  b64_encoding_enableds      rP   r4  %AsyncFastAPI.supports_base64_encoding  sE      #'"<"<">>##''(BEJ 
 $#	 ?   ?='?zAsyncFastAPI.get_max_batch_sizec                    #    U R                  5       I S h  vN n[        [        UR                  SS5      5      nU$  N&7f)Nr9  )rZ  r   r   r   )rN   rY  r9  s      rP   r;  AsyncFastAPI.get_max_batch_size"  s?      #'"<"<">>c#4#8#89I2#NO ?r_  )rM   rG   rH   rI   rY  )rS   r:   rm   )a__name__
__module____qualname____firstlineno__r<   r
   r   r{   r|   __annotations__r   rD   rX   r`   r   rg   r   rn   rV   r   rK   r   r   r   r   r   	OPERATIONr   r   r   r   r   r   r   r	   r   r   r   r   r   r   r   r   r   r   r'   r   r0   rM  r   r   r   r   r   r   r   r&   r  r)   INDEX_AND_WALr   r!   r/   r  r  r  r-   r  r4   r$   r+   r,   r%   r  r,  ALLr   r#   r(   r"   r*   r6  r<  rA  rD  r5   r.   rJ  rO  rS  r   rV  rZ  r4  r;  __static_attributes____classcell__)rO   s   @rP   r:   r:   ?   s    .0Hd3)))*/
v 
""
   PT   (U.. (> 0WS#X%6 0 0 S  ++!$+04S#X+	+$ *,D,N,NO5 5  P5 02J2T2TU %	
	
 	
 
		
  V	
 -/G/Q/QR %

 
 
	
  S
 02J2T2TU %

 
 
	
  V
 /1I1S1ST  $ $$	
}
 
 	

 
(	
  U
, .0H0R0RS
 
 
  T
 +-E-O-OP.S .V .  Q. 24L4V4VWS S  XS 13K3U3UV  $ $$(}  	
  
/	"  W. 24L4V4VW*<L$$69$	$  X$ 24L4V4VW $(AE15#$(     =>	
 -.    
  X@ /1I1S1ST %(	  	
 
  U /1I1S1S  $(AE15$(

  
   =>	

 -.
 
 
 

 
& (*B*L*LM #'59EI$(

 3-
 12	

 $$AB
 
 
 

  N
. &(@(J(JK
 %(  	
  
  L +-E-O-O  %(	

 
 	

 

 
" (*B*L*LM
 %( ) 7 7 ' ' v, ' 	 '
  '  ' 
 '  N 'D 24L4V4VW %(		
	
 	
 		

 
	
  X	
 ')A)K)KL %(	$$ $ 	$
 
$  M$ &(@(J(JK $(  	
  
  L" %'?'I'IJ "!%# $263$(+
+
 c]+
 	+

 }+
 +
 !/+
 +
 +
 +
 
+
  K+
Z (*B*L*LM "!%26$( c] 	
 !/   
  N  .0H0L0LM%
Z YYTN	
%
 %
 
%
 N%
N %'?'C'CD *.)-#$(  	
 I& I& tn   
  E2 (*B*F*FG
 ,0)-)-#$(  Z(	
 I& I& tn   
  H6 (*B*F*FG *.)-#$(  	
 I& I& tn   
  H2 ')A)E)EF
 "!%26<$(3
3
 %3
 c]	3

 3
 3
 !/3
 3
 3
 3
 
3
  G3
j &(@(D(DE%T %  F% ,.F.P.PQ$3 $  R$ h   ,.F.P.P&S && /1I1S1S$ $$ 35M5W5WX#   YrR   r:   )Pru   uuidr   urllib.parser   r   typingr   r   r   r   r   r	   r
   r   loggingr{   	overridesr   chromadbr   chromadb.authr   chromadb.api.async_apir   chromadb.api.base_http_clientr   %chromadb.api.collection_configurationr   r   r   r   chromadb.configr   r   r   r    chromadb.telemetry.opentelemetryr   r   r   chromadb.telemetry.productr   chromadb.utils.async_to_syncr   chromadb.typesr   r   r    r   "chromadb.execution.expression.planr!   chromadb.api.typesr"   r#   r$   r%   r&   r'   r(   r)   r*   r+   r,   r-   r.   r/   r0   r1   r2   r3   r4   r5   r6   r7   r8   	getLoggerrc  loggerr:   r   rR   rP   <module>r     s        L L L      & 1 8  O N 
 > 6 J J 5     .  
		8	$h>> hrR   