
    3id                        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  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.J/r0  S SK1J2r2  S SK3J4r4J5r5J6r6J7r7J8r8J9r9J:r:J;r;J<r<J=r=J>r>J?r?J@r@JArAJBrBJCrCJDrDJErE  S SK3JFrFJGrGJHrH  \R                  " \J5      rK " S S\\5      rLg)    N)UUID)Any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Schema	Metadatas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                     ^  \ rS rSr% 0 r\\\R                  4   \	S'   S\
4U 4S jjrSqS jrSrS jrS	\S
\S\SS4S jr\SrU 4S jj5       rS\R                  4S jrS\S\S\\\4   S\4S jr\" S\R.                  5      \S\4S j5       5       r\" S\R.                  5      \\4S\S\SS4S jj5       5       r\" S\R.                  5      \\4S\S\S\4S jj5       5       r\" S\R.                  5      \\4S\S\SS4S jj5       5       r\" S\R.                  5      \SS\4S\\   S\\   S\S\\   4S  jj5       5       r \" S!\R.                  5      \S\SS4S" j5       5       r!\" S#\R.                  5      \S\S\"4S$ j5       5       r#\" S%\R.                  5      \S\$4S& j5       5       r%\" S'\R.                  5      \SS\\&4S\\   S\\   S\S(\S\\'   4
S) jj5       5       r(\" S*\R.                  5      \\\&4S\S(\S\4S+ jj5       5       r)\" S,\R.                  5      \SSSS-\\&4S\S.\\*   S/\\+   S0\\,   S1\-S\S(\S\'4S2 jj5       5       r.\" S3\R.                  5      \\\&4S\S\S(\S\'4S4 jj5       5       r/\" S5\R.                  5      \SSS\\&4S\S.\\*   S/\\+   S0\\,   S\S(\S\'4S6 jj5       5       r0\" S7\R.                  5      \SSS\\&4S8\1S9\\   S:\\,   S;\\2   S\S(\SS4S< jj5       5       r3\" S=\R.                  5      \\\&4S>\1S9\S\S(\S\'4
S? jj5       5       r4\" S@\R.                  5      \\\&4S>\1SA\5\6   S\S(\S\74
SB jj5       5       r8\" SC\R.                  5      \\\&4S\S\S(\SS4SD jj5       5       r9\" SE\R.                  5      \\\&4S>\1S\S(\S\4SF jj5       5       r:\" SG\R.                  5      \SH\\&4S>\1SI\S\S(\S\;4
SJ jj5       5       r<\" SK\R.                  5      \SSSSS\=\\&4S>\1SL\\>   SM\\?   S\\   S\\   SN\\@   SO\AS\S(\S\;4SP jj5       5       rB\" SQ\R.                  5      \SSS\\&4S>\1SL\\>   SM\\?   SN\\@   S\S(\SS4SR jj5       5       rC\" SS\R                  5      ST\E\>\\F   \\G   \\H   \\I   4   SU\S\4SV j5       rJ\" SW\R                  5      \SSS\\&4SL\>S>\1SX\FSY\\G   SZ\\H   S[\\I   S\S(\S\-4S\ jj5       5       rK\" S]\R                  5      \SSSS\\&4S>\1SL\>SX\\F   SY\\G   SZ\\H   S[\\I   S\S(\S\-4S^ jj5       5       rL\" S_\R                  5      \SSS\\&4S>\1SL\>SX\FSY\\G   SZ\\H   S[\\I   S\S(\S\-4S` jj5       5       rM\" Sa\R                  5      \SSHSS\N\\&4S>\1Sb\FSL\\>   Sc\SM\\?   SN\\@   SO\AS\S(\S\O4Sd jj5       5       rP\" Se\R                  5      \S\-4Sf j5       5       rQ\" Sg\R.                  5      \S\4Sh j5       5       rR\S\S4Si j5       rT\" Sj\R.                  5      S\4Sk j5       rU\" Sl\R.                  5      S\-4Sm j5       rV\" Sn\R.                  5      \S\4So j5       5       rWSprXU =rY$ )s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	_settingsr7   resolve_urlstrr<   r=   r>   chroma_server_api_default_path_api_url)selfr:   	__class__s     T/home/james-whalen/.local/lib/python3.13/site-packages/chromadb/api/async_fastapi.pyrA   AsyncFastAPI.__init__H   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rK   s    rM   
__aenter__AsyncFastAPI.__aenter__Y   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   )lenr9   popitemaclose)rK   _clients      rM   _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rR   r]   )rK   r_   r`   ra   s       rM   	__aexit__AsyncFastAPI.__aexit__b   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rR   rc   rT   s   rM   sync_cleanup'AsyncFastAPI.stop.<locals>.sync_cleanupi   s     --/!!s   rP   N)r@   stopr   )rK   rh   rL   s   ` rM   rk   AsyncFastAPI.stope   s%    		" 
	" 	rO   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                  " U R                  S9n[        R                  " S UU R
                  R                  =(       d    SU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-Agent)keepalive_expiryF)timeoutheadersverifylimits)asyncioget_event_loop__hash__RuntimeErrorr9   rF   chroma_server_headerscopyr   httpxLimitskeepalive_secsAsyncClientchroma_server_ssl_verify)rK   	loop_hashlooprp   rr   s        rM   rS   AsyncFastAPI._get_cliento   s     		))+DI MM)~~;;ArGGIG&8GN#(<= L! \\43F3FGF','8'8~~>>G%	(DMM)$ }}Y'')  	I	s   %C' 'C65C6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quoterJ   rS   requestr   r   r   _raise_chroma_errorloadstext)rK   r   r   r   dataescaped_pathurlresponses           rM   _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)rK   r   s     rM   	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   rK   r   r   s      rM   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   )rK   r   r   r   s       rM   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      rM   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   )rK   r   r   r   r   dbs         rM   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   )rK   r   s     rM   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   )rK   r   	resp_jsons      rM   
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   rT   s    rM   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)rK   r   r   r   r   r   json_collectionmodelss           rM   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   )rK   r   r   r   s       rM   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   )rK   r   r   r   r   r   r   r   config_jsonserialized_schemar   models               rM   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   )rK   r   r   r   r   r   s         rM   get_collectionAsyncFastAPI.get_collectionH  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   )rK   r   r   r   r   r   r   s          rM   get_or_create_collection%AsyncFastAPI.get_or_create_collectionY  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   )rK   r   r   r   r   r   r   s          rM   _modifyAsyncFastAPI._modifyp  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   )rK   r   r   r   r   r   r   s          rM   _forkAsyncFastAPI._fork  sa      ,,x{8*M-PUVh' - 
 
	
  )))4
s   !AA AzAsyncFastAPI._searchsearchesc           
      p  #    SU Vs/ s H  oUR                  5       PM     sn0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 collectionr   r   r   r   r   z/searchr   N	metadatas)to_dictr   r   r5   r,   )rK   r   r   r   r   spayloadr   metadata_batchesr   r   s              rM   _searchAsyncFastAPI._search  s      X>X		X>?,,x{8*M-PWX - 
 
	 %==d;' "2& "2I ( %.$- 7?6J(2PTT$-
  "2&Ik" I&&)  ?
&s?   B6B$"B6B)B6"B0/B+		B0B6+B00B6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   )rK   r   r   r   s       rM   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   )rK   r   r   r   r   s        rM   _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)_getr3   )rK   r   r  r   r   resps         rM   _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   r5   r*   )rK   r   r  r  r   r   r  r
  r   r   ifiltered_includer   r   r   s                  rM   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   )rK   r   r  r  r  r   r   s          rM   _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_encodingr4   r.   r   )rK   r  r   r#  serialized_metadatasr   r   s          rM   _submit_batchAsyncFastAPI._submit_batch+  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r/   get_max_batch_sizer%  rH   )
rK   r  r   r  r   r  r  r   r   r  s
             rM   _addAsyncFastAPI._addS  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)Nr(  r   r   r   z/updateTr)  
rK   r   r  r  r   r  r  r   r   r  s
             rM   _updateAsyncFastAPI._updaten  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)Nr(  r   r   r   z/upsertTr)  r/  s
             rM   _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  r5  r6  r  r  r
  r   r   r  	distancesr  r  r  )r  r8  r  r   r  r  r   r  )r   r0   r   r5   r+   )rK   r   r5  r  r6  r  r  r
  r   r   r  r  r   r   r   r   s                   rM   _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rK   r   s     rM   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   rH   r=  s     rM   get_versionAsyncFastAPI.get_version  s/      ,,UJ??	C## @r@  c                     U R                   $ rR   )rF   rT   s    rM   get_settingsAsyncFastAPI.get_settings  s    ~~rO   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   r=  s     rM   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)Nr#  F)rI  r   r<  r   )rK   rH  b64_encoding_enableds      rM   r#  %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)Nr(  )rI  r   r   r   )rK   rH  r(  s      rM   r*  AsyncFastAPI.get_max_batch_size   s?      #'"<"<">>c#4#8#89I2#NO ?rN  )rJ   rD   rE   rF   rH  )rP   r7   rj   )Z__name__
__module____qualname____firstlineno__r9   r	   r   ry   r|   __annotations__r   rA   rU   r]   r   rd   r   rk   rS   rH   r   r   r   	OPERATIONr   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r   r%   r   r-   r<  r   r   r   r   r   r   r   r
   r    r,   r   r  r  r*   r  r1   r#   r(   r)   r$   r  r  ALLr   r"   r&   r!   r'   r%  r+  r0  r3  r2   r+   r9  r>  rB  r   rE  rI  r#  r*  __static_attributes____classcell__)rL   s   @rM   r7   r7   =   s
    .0Hd3)))*/
v 
""
   PT   (U.. (@++!$+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 (*B*L*LM
 %('' v,' 	'
 ' 
'  N'< 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rO   r7   )Mrs   uuidr   urllib.parser   r   typingr   r   r   r   r   r	   r
   loggingry   	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.   r/   r0   r1   r2   r3   r4   r5   	getLoggerrR  loggerr7   r   rO   rM   <module>rn     s        C C C      & 1 8  O N 
 > 6 J J 5    *  
		8	$H>> HrO   