codekingpro/portable-devtools
114k
1�
2 ��j�i � �j � S SK JrJr S SKJrJrJr S SKJr S SK J3r4 S SK J r J
r
S SKJr S SKJr S SKJrJr S S KJrJrJrJrJrJrJ r J r J r J r J r J!r!J"r"J#r#J$r$J%r%J&r&J'r'J(r(J)r)J*r*J+r+J,r, S S5K-J.r. S S KJ/r/J0r0 S S K1J2r2J3r3J4r5 " S
S\5 r6 " S S\6\5 r7 " S S\5 r8 " S S\6\8\/5 r9g)� )�ABC�abstractmethod)�Sequence�Optional�List)�UUID)�override)� CreateCollectionConfiguration� UpdateCollectionConfiguration)� UserIdentity)�AsyncCollection)�DEFAULT_DATABASE�DEFAULT_TENANT)�CollectionMetadata� DeleteResult� Documents�6Embeddable�EmbeddingFunction�7DataLoader�8Embeddings�IDs�Include�IndexingStatus�Loadable� Metadatas� ReadLevel�Schema�URIs�Where� QueryResult� GetResult�
WhereDocument�IncludeMetadataDocuments�!IncludeMetadataDocumentsDistances� SearchResult�DefaultEmbeddingFunction)�Search)� Component�Settings)�Database�Tenant�9Collectionc �L � \ rS rSr\S\4S j5 r\S\4S j5 r\ S*S\S\ \10 S\ \ S \ \ SS411S12 jj5 r
\S \13SS4S j5 r\ S*S
\S\S\S\ \ S\ \ S\ \ S\4S jj5 r\ S+S\S
\S\ \ S\ \ S\ \ S\ \ S\4S jj5 r\ S*S\S
\S\S\ \ S\ \ S\ \ S\4S jj5 r\S\S\4S j5 r\S,S\S\S\4S jj5 r\SSSSS\4S\S
\ \ S\ \ S\ \ S \ \ S \ \ S \ S\4S jj5 r \ S*S\S
\ \ S\ \ S \ \ S\ \ S\ 4 S jj5 r!\SSSS\"4S\S!\S
\ \ S"\S\ \ S \ \ S \ S\#4S# jj5 r$\S\4S$ j5 r%\S\144S% j5 r&\S\'4S& j5 r(\S\4S' j5 r)\S\*4S( j5 r+S)r,g)-� AsyncBaseAPI�+ �returnc � � # � g7f)z�Get the current time in nanoseconds since epoch.15Used to check if the server is alive.16 17Returns:18 int: The current time in nanoseconds since epoch19 20N� ��selfs �\D:\code\apps\devtools\python\user_packages\Python313\site-packages\chromadb/api/async_api.py� heartbeat�AsyncBaseAPI.heartbeat, �21 � � �
�� �c � � # � g7f)z�Count the number of collections.22 23Returns:24 int: The number of collections.25 26Examples:27 ```python28 await client.count_collections()29 # 130 ```31Nr2 r3 s r5 �count_collections� AsyncBaseAPI.count_collections; �32 � � �
�r9 N�id�new_name� new_metadata�new_configurationc � � # � g7f)a� [Internal] Modify a collection by UUID. Can update the name and/or metadata.33 34Args:35 id: The internal UUID of the collection to modify.36 new_name: The new name of the collection.37 If None, the existing name will remain. Defaults to None.38 new_metadata: The new metadata to associate with the collection.39 Defaults to None.40 new_configuration: The new configuration to associate with the collection.41 Defaults to None.42Nr2 )r4 r> r? r@ rA s r5 �_modify�AsyncBaseAPI._modifyJ s43 � � �&
�r9 �namec � � # � g7f)z�Delete a collection with the given name.44Args:45 name: The name of the collection to delete.46 47Raises:48 ValueError: If the collection does not exist.49 50Examples:51 ```python52 await client.delete_collection("my_collection")53 ```54Nr2 �r4 rE s r5 �delete_collection� AsyncBaseAPI.delete_collection_ s55 � � �"
�r9 �ids�
collection_id�56embeddings� metadatas� documents�urisc � � # � g7f)aX [Internal] Add embeddings to a collection specified by UUID.57If (some) ids already exist, only the new embeddings will be added.58 59Args:60 ids: The ids to associate with the embeddings.61 collection_id: The UUID of the collection to add the embeddings to.62 embedding: The sequence of embeddings to add.63 metadata: The metadata to associate with the embeddings. Defaults to None.64 documents: The documents to associate with the embeddings. Defaults to None.65 uris: URIs of data sources for each embedding. Defaults to None.66 67Returns:68 True if the embeddings were added successfully.69Nr2 )r4 rJ rK rL rM rN rO s r5 �_add�AsyncBaseAPI._addv s70 � � �0
�r9 c � � # � g7f)a' [Internal] Update entries in a collection specified by UUID.71 72Args:73 collection_id: The UUID of the collection to update the embeddings in.74 ids: The IDs of the entries to update.75 embeddings: The sequence of embeddings to update. Defaults to None.76 metadatas: The metadata to associate with the embeddings. Defaults to None.77 documents: The documents to associate with the embeddings. Defaults to None.78 uris: URIs of data sources for each embedding. Defaults to None.79Returns:80 True if the embeddings were updated successfully.81Nr2 �r4 rK rJ rL rM rN rO s r5 �_update�AsyncBaseAPI._update� �82 � � �,
�r9 c � � # � g7f)aD [Internal] Add or update entries in the a collection specified by UUID.83If an entry with the same id already exists, it will be updated,84otherwise it will be added.85 86Args:87 collection_id: The collection to add the embeddings to88 ids: The ids to associate with the embeddings. Defaults to None.89 embeddings: The sequence of embeddings to add90 metadatas: The metadata to associate with the embeddings. Defaults to None.91 documents: The documents to associate with the embeddings. Defaults to None.92 uris: URIs of data sources for each embedding. Defaults to None.93Nr2 rT s r5 �_upsert�AsyncBaseAPI._upsert� rW r9 c � � # � g7f)z�[Internal] Returns the number of entries in a collection specified by UUID.94 95Args:96 collection_id: The UUID of the collection to count the embeddings in.97 98Returns:99 int: The number of embeddings in the collection100 101Nr2 )r4 rK s r5 �_count�AsyncBaseAPI._count� �102 � � �
�r9 �103 �nc � � # � g7f)a [Internal] Returns the first n entries in a collection specified by UUID.104 105Args:106 collection_id: The UUID of the collection to peek into.107 n: The number of entries to peek. Defaults to 10.108 109Returns:110 GetResult: The first n entries in the collection.111 112Nr2 )r4 rK r` s r5 �_peek�AsyncBaseAPI._peek� r= r9 �where�limit�offset�where_document�includec � � # � g7f)ah [Internal] Returns entries from a collection specified by UUID.113 114Args:115 ids: The IDs of the entries to get. Defaults to None.116 where: Conditional filtering on metadata. Defaults to None.117 limit: The maximum number of entries to return. Defaults to None.118 offset: The number of entries to skip before returning. Defaults to None.119 where_document: Conditional filtering on documents. Defaults to None.120 include: The fields to include in the response.121 Defaults to ["embeddings", "metadatas", "documents"].122Returns:123 GetResult: The entries in the collection that match the query.124 125Nr2 )r4 rK rJ rd re rf rg rh s r5 �_get�AsyncBaseAPI._get� �126 � � �2
�r9 c � � # � g7f)a) [Internal] Deletes entries from a collection specified by UUID.127 128Args:129 collection_id: The UUID of the collection to delete the entries from.130 ids: The IDs of the entries to delete. Defaults to None.131 where: Conditional filtering on metadata. Defaults to None.132 where_document: Conditional filtering on documents. Defaults to None.133 limit: Maximum number of records to delete. Can only be used with134 where or where_document. Defaults to None (no limit).135 136Returns:137 DeleteResult: A dict containing the number of records deleted.138Nr2 )r4 rK rJ rd rg re s r5 �_delete�AsyncBaseAPI._delete� rW r9 �query_embeddings� n_resultsc � � # � g7f)aR [Internal] Performs a nearest neighbors query on a collection specified by UUID.139 140Args:141 collection_id: The UUID of the collection to query.142 query_embeddings: The embeddings to use as the query.143 n_results: The number of results to return. Defaults to 10.144 where: Conditional filtering on metadata. Defaults to None.145 where_document: Conditional filtering on documents. Defaults to None.146 include: The fields to include in the response.147 Defaults to ["embeddings", "metadatas", "documents", "distances"].148 149Returns:150 QueryResult: The results of the query.151Nr2 )r4 rK rp rJ rq rd rg rh s r5 �_query�AsyncBaseAPI._query rl r9 c � � # � g7f)z�Resets the database. This will delete all collections and entries.152 153Returns:154 bool: True if the database was reset successfully.155Nr2 r3 s r5 �reset�AsyncBaseAPI.reset* �156 � � �
�r9 c � � # � g7f)zEGet the version of Chroma.157 158Returns:159 str: The version of Chroma160 161Nr2 r3 s r5 � get_version�AsyncBaseAPI.get_version3 �162 � � �
�r9 c � � g)z_Get the settings used to initialize.163 164Returns:165 Settings: The settings used to initialize.166 167Nr2 r3 s r5 � get_settings�AsyncBaseAPI.get_settings= s � �
� c � � # � g7f)zUReturn the maximum number of records that can be created or mutated in a single call.Nr2 r3 s r5 �get_max_batch_size� AsyncBaseAPI.get_max_batch_sizeG s168 � � �
�r9 c � � # � g7f)zcResolve the tenant and databases for the client. Returns the default169values if can't be resolved.170 171Nr2 r3 s r5 �get_user_identity� AsyncBaseAPI.get_user_identityL s172 � � �
�r9 r2 )NNN)NNNN)r_ )-�__name__�173__module__� __qualname__�__firstlineno__r �intr6 r; r r �strr r rC rH r r r r r �boolrQ rU rY r\ r! rb r# r r" r rj r rn r$ r rs rv rz r) r~ r� r r� �__static_attributes__r2 r� r5 r. r. + s] � ��
��
� �
� �
��
� �
� � #'�59�EI�
� �
� �3�-�
� � 1�2�
�174 $�$A�B�
� 175�
� �
�( �
��
� 176�
� �
�, � *.�)-� #�
�
�
� �
� �
�177 �I�&�
� �I�&�
� �t�n�
� 178�
� �
�2 �179 ,0�)-�)-� #�
��
� �
� �Z�(�
�180 �I�&�
� �I�&�
� �t�n�
� 181�
� �
�. � *.�)-� #�
��
� �
� �
�182 �I�&�
� �I�&�
� �t�n�
� 183�
� �
�. �184
�$� 185
�3� 186
� �187
� �
��
�#�
�y�
� �
� � "�!%� #� $�26�3�
��
� �c�]�
� ���
�188 ��}�
� ��
�
� !� �/�
� �
� 189�
� �
�4 �190 "&�26� #�
��
� �c�]�
� ���
�191 !� �/�
� ��}�
� 192�
� �
�. �193 "��!%�26�<�
��
� %�
� �c�]�
�194 �
� ���
� !� �/�
� �
� 195�
� �
�4 �
�T�
� �
� �
�3�
� �
� �
�h�
� �
� �
�#�
� �
� �
� �
� �
r� r. c �J � \ rS rSr% \\S' \\S' \ SS\\ S\\ S\ \196 4S jj5 r \SSS\ " 5 SS 4S197\S \\
S \\ S
\\ S\\\ S\\\ S\S\1984S jj5 r\\ " 5 S4S199\S\\\ S\\\ S\2004S jj5 r\\ " 5 S4S\S\\\ S\\\ S\2014S jj5 r\SSS\ " 5 S4S202\S \\
S \\ S
\\ S\\\ S\\\ S\2034S jj5 r\\4S\S\SS4S jj5 r\S\SS4S j5 r \ \SS j5 5 r Sr g) �AsyncClientAPIiU �tenant�databaseNre rf r0 c � � # � g7f)ak List all collections.204Args:205 limit: The maximum number of entries to return. Defaults to None.206 offset: The number of entries to skip before returning. Defaults to None.207 208Returns:209 Sequence[AsyncCollection]: A list of collections.210 211Examples:212 ```python213 await client.list_collections()214 # [collection(name="my_collection", metadata={})]215 ```216Nr2 )r4 re rf s r5 �list_collections� AsyncClientAPI.list_collectionsY �217 � � �(
�r9 FrE �schema�
configuration�metadata�embedding_function� data_loader�
get_or_createc � � # � g7f)a� Create a new collection with the given name and metadata.218Args:219 name: The name of the collection to create.220 metadata: Optional metadata to associate with the collection.221 embedding_function: Optional function to use to embed documents.222 Uses the default embedding function if not provided.223 get_or_create: If True, return the existing collection if it exists.224 data_loader: Optional function to use to load records (documents, images, etc.)225 226Returns:227 Collection: The newly created collection.228 229Raises:230 ValueError: If the collection already exists and get_or_create is False.231 ValueError: If the collection name is invalid.232 233Examples:234 ```python235 await client.create_collection("my_collection")236 # collection(name="my_collection", metadata={})237 238 await client.create_collection("my_collection", metadata={"foo": "bar"})239 # collection(name="my_collection", metadata={"foo": "bar"})240 ```241Nr2 )r4 rE r� r� r� r� r� r� s r5 �create_collection� AsyncClientAPI.create_collectiono s � � �L
�r9 c � � # � g7f)a' Get a collection with the given name.242Args:243 name: The name of the collection to get244 embedding_function: Optional function to use to embed documents.245 Uses the default embedding function if not provided.246 data_loader: Optional function to use to load records (documents, images, etc.)247 248Returns:249 Collection: The collection250 251Raises:252 ValueError: If the collection does not exist253 254Examples:255 ```python256 await client.get_collection("my_collection")257 # collection(name="my_collection", metadata={})258 ```259Nr2 )r4 rE r� r� s r5 �get_collection� AsyncClientAPI.get_collection� s260 � � �8
�r9 r> c � � # � g7f)a1 Get a collection by its ID.261 262Args:263 id: The UUID of the collection to get.264 embedding_function: Optional function to use to embed documents.265 Uses the default embedding function if not provided.266 data_loader: Optional function to use to load records (documents, images, etc.)267 268Returns:269 Collection: The collection270 271Raises:272 NotFoundError: If no collection with the given ID exists.273 274Examples:275 ```python276 await client.get_collection_by_id(uuid.UUID("..."))277 # collection(name="my_collection", metadata={})278 ```279Nr2 )r4 r> r� r� s r5 �get_collection_by_id�#AsyncClientAPI.get_collection_by_id� s280 � � �:
�r9 c � � # � g7f)a� Get or create a collection with the given name and metadata.281Args:282 name: The name of the collection to get or create283 metadata: Optional metadata to associate with the collection. If284 the collection already exists, the metadata provided is ignored.285 If the collection does not exist, the new collection will be created286 with the provided metadata.287 embedding_function: Optional function to use to embed documents288 data_loader: Optional function to use to load records (documents, images, etc.)289 290Returns:291 The collection292 293Examples:294 ```python295 await client.get_or_create_collection("my_collection")296 # collection(name="my_collection", metadata={})297 ```298Nr2 )r4 rE r� r� r� r� r� s r5 �get_or_create_collection�'AsyncClientAPI.get_or_create_collection� s299 � � �>
�r9 c � � # � g7f)z�Set the tenant and database for the client. Raises an error if the tenant or300database does not exist.301 302Args:303 tenant: The tenant to set.304 database: The database to set.305 306Nr2 �r4 r� r� s r5 �307set_tenant�AsyncClientAPI.set_tenant� �308 � � �
�r9 c � � # � g7f)z|Set the database for the client. Raises an error if the database does not exist.309 310Args:311 database: The database to set.312 313Nr2 )r4 r� s r5 � set_database�AsyncClientAPI.set_database r| r9 c � � g)z~Clear the system cache so that new systems can be created for an existing path.314This should only be used for testing purposes.Nr2 r2 r� r5 �clear_system_cache�!AsyncClientAPI.clear_system_cache s � �315
r� r2 )NN)r0 N) r� r� r� r� r� �__annotations__r r r� r r
r� r& r r316 r r r r r r� r� r� r r� r� r r� r� � staticmethodr� r� r2 r� r5 r� r� U s� � � �K��M�� $� $�
���}�
� ��
�
� 317�/� "�
� �
�* � $(�AE�15�
%� &�6:� #�%
��%
� �� �%
� � =�>� %
�318 �-�.� %
� %� �j� )� 319�
%
� �j�� 2�3�%
� �%
� 320�%
� �%
�N �
%� &�6:�
��
� %� �j� )� 321�
� �j�� 2�3�
� 322�
� �
�: �
%� &�6:�
� �
� %� �j� )� 323�
� �j�� 2�3�
� 324�
� �
�< � $(�AE�15�
%� &�6:�
��
� �� �
� � =�>�
�325 �-�.�
� %� �j� )� 326�
� �j�� 2�3�
� 327�
� �
�@ �<L�
�s�
�c�
�QU�
� �
� �
�3�
�4�
� �
� ��
� � �
r� r� c �� � \ rS rSr\\4S\S\SS4S jj5 r\\4S\S\S\4S jj5 r \\4S\S\SS4S jj5 r328\SS\4S \ \ S329\ \ S\S\
\ 4S jj5 r\S\SS4S j5 r\S\S\4S
j5 rSrg)�
AsyncAdminAPIi rE r� r0 Nc � � # � g7f)z�Create a new database. Raises an error if the database already exists.330 331Args:332 database: The name of the database to create.333 334Nr2 �r4 rE r� s r5 �create_database� AsyncAdminAPI.create_database r| r9 c � � # � g7f)z�Get a database. Raises an error if the database does not exist.335 336Args:337 database: The name of the database to get.338 tenant: The tenant of the database to get.339 340Nr2 r� s r5 � get_database�AsyncAdminAPI.get_database r8 r9 c � � # � g7f)z�Delete a database. Raises an error if the database does not exist.341 342Args:343 database: The name of the database to delete.344 tenant: The tenant of the database to delete.345 346Nr2 r� s r5 �delete_database� AsyncAdminAPI.delete_database) r8 r9 re rf c � � # � g7f)z�List all databases for a tenant. Raises an error if the tenant does not exist.347 348Args:349 tenant: The tenant to list databases for.350 351Nr2 )r4 re rf r� s r5 �list_databases� AsyncAdminAPI.list_databases4 r= r9 c � � # � g7f)zyCreate a new tenant. Raises an error if the tenant already exists.352 353Args:354 tenant: The name of the tenant to create.355 356Nr2 rG s r5 �
create_tenant�AsyncAdminAPI.create_tenantC r| r9 c � � # � g7f)zoGet a tenant. Raises an error if the tenant does not exist.357 358Args:359 tenant: The name of the tenant to get.360 361Nr2 rG s r5 �362get_tenant�AsyncAdminAPI.get_tenantM r| r9 r2 )r� r� r� r� r r r� r� r* r� r� r r� r r� r� r+ r� r� r2 r� r5 r� r� s � ��=K�
�#�
�s�
�PT�
� �
� �:H�
�s�
�C�
�X�
� �
� �=K�
�#�
�s�
�PT�
� �
� � $� $�$�
���}�
� ��
�
� �
�363 364�(� �
� �
� �
��
��
� �
� �
�S�
�V�
� �
r� r� c �� � \ rS rSrSr\SS\\4S\\ S\\ S\365S\366S\ \ 4367S jj5 r
\\\\4S\368S\369S\ 4S370 jj5 5 r\SSSS \\4S \371S
\\ S\\ S\\ S\S\372S\373S\ 4S jj5 r\\\4S \374S\375S\376S\ 4S jj5 r\\\4S\S\377S\378S\ 4S jj5 r\SSS\\4S \379S
\\ S\\ S\\ S\380S\381S\ 4S jj5 r\\\\4S \382S\383S\384SS4S jj5 5 r\\SSS\\4S\S\\385 S\\ S\\ S\386S\387SS4S jj5 5 r\\\4S\S\388S\389S\390S\ 4391S jj5 r \\\4S\S\392S\393S\ 4S jj5 r \\\4S\S\394S\395SS 4S jj5 r \\\\ R@ 4S\S \!\" S\396S\397S!\ S\#4 S" jj5 r$\\\\\ R@ 4S\S\398S\399S!\ S\ 4400S# jj5 5 r%\\S$\\4S\S%\ S\401S\402S\&4403S& jj5 5 r'\\SSSSS\(\\4S\S'\\) S(\\* S\\ S\\ S)\\+ S*\,S\404S\405S\&4S+ jj5 5 r-\\SSS\\4S'\)S\S,\.S-\\/ S.\\0 S/\\1 S\406S\407S\4S0 jj5 5 r2\\SSSS\\4S\S'\)S,\\. S-\\/ S.\\0 S/\\1 S\408S\409S\4S1 jj5 5 r3\\SSS\\4S\S'\)S,\.S-\\/ S.\\0 S/\\1 S\410S\411S\4S2 jj5 5 r4\\SS$SS\5\\4S\S3\.S'\\) S4\ S(\\* S)\\+ S*\,S\412S\413S\64S5 jj5 5 r7\\SSSS\\4S\S'\\) S(\\* S)\\+ S\\ S\414S\415S\84S6 jj5 5 r9S7r:g)8�AsyncServerAPIiX z�An API instance that extends the relevant Base API methods by passing416in a tenant and database. This is the root component of the Chroma SystemNre rf r� r� r0 c � � # � g 7f�Nr2 )r4 re rf r� r� s r5 r� � AsyncServerAPI.list_collections\ r| r9 c � � # � g 7fr� r2 r� s r5 r; � AsyncServerAPI.count_collectionsf s417 � � �418
�r9 FrE r� r� r� r� c � � # � g 7fr� r2 )r4 rE r� r� r� r� r� r� s r5 r� � AsyncServerAPI.create_collectionm r^ r9 c � � # � g 7fr� r2 �r4 rE r� r� s r5 r� � AsyncServerAPI.get_collectionz rx r9 rK c � � # � g7f)a< Get a collection by its ID.419 420Args:421 collection_id: The UUID of the collection to retrieve.422 tenant: The tenant to search within.423 database: The database to search within.424 425Returns:426 CollectionModel: The collection with the given ID.427 428Raises:429 NotFoundError: If no collection with the given ID exists.430Nr2 �r4 rK r� r� s r5 r� �#AsyncServerAPI.get_collection_by_id� r� r9 c � � # � g 7fr� r2 )r4 rE r� r� r� r� r� s r5 r� �'AsyncServerAPI.get_or_create_collection� r� r9 c � � # � g 7fr� r2 r� s r5 rH � AsyncServerAPI.delete_collection� r| r9 r> r? r@ rA c � � # � g 7fr� r2 )r4 r> r? r@ rA r� r� s r5 rC �AsyncServerAPI._modify� r^ r9 c � � # � g 7fr� r2 )r4 rK r? r� r� s r5 �_fork�AsyncServerAPI._fork� r| r9 c � � # � g 7fr� r2 r� s r5 � _fork_count�AsyncServerAPI._fork_count� rx r9 r c � � # � g 7fr� r2 r� s r5 �_get_indexing_status�#AsyncServerAPI._get_indexing_status� rx r9 �searches�431read_levelc � � # � g 7fr� r2 )r4 rK r� r� r� r� s r5 �_search�AsyncServerAPI._search� r8 r9 c � � # � g 7fr� r2 )r4 rK r� r� r� s r5 r\ �AsyncServerAPI._count� r8 r9 r_ r` c � � # � g 7fr� r2 )r4 rK r` r� r� s r5 rb �AsyncServerAPI._peek� r8 r9 rJ rd rg rh c432 � � # � g 7fr� r2 )433r4 rK rJ rd re rf rg rh r� r� s434 r5 rj �AsyncServerAPI._get� �435 � � �
�r9 rL rM rN rO c � � # � g 7fr� r2 ) r4 rJ rK rL rM rN rO r� r� s r5 rQ �AsyncServerAPI._add r= r9 c � � # � g 7fr� r2 � r4 rK rJ rL rM rN rO r� r� s r5 rU �AsyncServerAPI._update r= r9 c � � # � g 7fr� r2 r� s r5 rY �AsyncServerAPI._upsert' r= r9 rp rq c436 � � # � g 7fr� r2 )437r4 rK rp rJ rq rd rg rh r� r� s438 r5 rs �AsyncServerAPI._query6 r� r9 c � � # � g 7fr� r2 )r4 rK rJ rd rg re r� r� s r5 rn �AsyncServerAPI._deleteF s439 � � �
�r9 r2 );r� r� r� r� �__doc__r r r r r� r� r �CollectionModelr� r r; r r440 r r� r� r� r r� r� rH r rC r� r� r� r �
INDEX_AND_WALr r' r% r� r\ r! rb r# r r r" r rj r r r r rQ rU rY r$ r rs r rn r� r2 r� r5 r� r� X sw � �Q� � $� $�$�(�
���}�
� ��
�
� �
�441 �
� 442�/� "�
� �
� �
� *�<L�
��
�69�
� �
� � �
�443 � $(�AE�15� #�$�(�444
��445
� �� �446
� � =�>� 447
�448 �-�.� 449
� �
450
� �451
� �452
� 453�454
� �455
� � %�(�
��
� �
� �
�456 457�
� �
� � %�(�
��
� �
� �
�458 459�
� �
�* � $(�AE�15�$�(�
��
� �� �
� � =�>�
�460 �-�.�
� �
� �
� 461�
� �
� �
� %�(�
��
� �
� �
�462 463�
� � �
� �
� #'�59�EI�$�(�
� �
� �3�-�
� � 1�2�
�464 $�$A�B�
� �
� �
� 465�
� � �
� �466 %�(�
��
� �
� �
�467 �
� 468�
� �
� � %�(�
��
� �
� �
�469 470
�
� �
� � %�(�
��
� �
� �
�471 472�
� �
� �473 %�(� )� 7� 7�
��
� �v�,�
� �
�474 �
� �
� 475�
� �
� �
� %�(� )� 7� 7�
��
� �
� �
�476 �
� 477
�
� � �
� �
� �$�(�
��
� �
� �
�478 �
� 479�
� � �
� �
� "�!%� #� $�26�3�$�(�
��
� �c�]�
� ���
�480 ��}�
� ��
�
� !� �/�
� �
� �
� �
� 481�
� � �
� �
� *.�)-� #�$�(�
�
�
� �
� �
�482 �I�&�
� �I�&�
� �t�n�
� �
� �
� 483�
� � �
� �
�484 ,0�)-�)-� #�$�(�
��
� �
� �Z�(�
�485 �I�&�
� �I�&�
� �t�n�
� �
� �
� 486�
� � �
� �
� *.�)-� #�$�(�
��
� �
� �
�487 �I�&�
� �I�&�
� �t�n�
� �
� �
� 488�
� � �
� �
�489 "��!%�26�<�$�(�
��
� %�
� �c�]�
�490 �
� ���
� !� �/�
� �
� �
� �
� 491�
� � �
� �
� "�!%�26� #�$�(�492
��493
� �c�]�494
� ��� 495
�496 !� �/� 497
� ��}�
498
� �499
� �500
� 501�502
� � �503
r� r� N):�abcr r �typingr r r �uuidr � overridesr �%chromadb.api.collection_configurationr504 r �
chromadb.authr �#chromadb.api.models.AsyncCollectionr
�chromadb.configr r �chromadb.api.typesr r r r r r r r r r r r r r r r r r! r" r# r$ r% r& �"chromadb.execution.expression.planr' r( r) �chromadb.typesr* r+ r, r r. r� r� r� r2 r� r5 �<module>r s� �� #� +� +� � �� '� ?� <�� � � � � � �2 6� /� J� J�g
�3� g
�T {
�\�3� {
�|B
�C� B
�Jz
�\�=�)� z
r�