Team Ai
Datasetpublic

codekingpro/portable-devtools

sourceHugging Faceupdated 5mo agoView on Hugging Face
1likes15kdownloads
async_fastapi.cpython-313.pyc346 linesDownload Raw Back to __pycache__
1�

2��j�q����SSKrSSKJr SSKrSSKrSSKJrJrJ	r	J3r4JrJrJ
r
Jr SSKrSSKrSSKJr SSKJr SSKJr SSKJr SSKJr SS	KJrJrJrJr SS5K J!r!J"r"J#r#J$r$ SSK%J&r&J'r'J(r( SSK)J*r* SS
K+J,r, SSK-J.r.J/r/J0r1 SSK2J3r3 SSK4J5r5J6r6J7r7J8r8J9r9J:r:J;r;J<r<J=r=J>r>J?r?J@r@JArAJBrBJCrCJDrDJErEJFrFJGrGJHrHJIrI SSK4JJrJJKrKJLrL \R�"\N5rO"SS\\5rPg)�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�6Collection)�Search)�DeleteResult�	Documents�7Embeddings�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�D^�\rSrSr%0r\\\R4\	S'S\84U4SjjrSzSjrS{Sjr
S	\S9\S\SS4Sjr\S{U4S
jj5rS\R4Sjr\S\\\44Sj5r\S\4Sj5rS\S\S\\\4S\4Sjr\"S\R45\S\4Sj55r\"S\R45\\4S\S\SS4Sjj55r\"S\R45\\4S\S\S\4Sjj55r\"S\R45\\4S\S\SS4Sjj55r \"S\R45\SS\4S \!\S!\!\S\S\"\4S"jj55r#\"S#\R45\S\SS4S$j55r$\"S%\R45\S\S\%4S&j55r&\"S'\R45\S\'4S(j55r(\"S)\R45\SS\\)4S \!\S!\!\S\S*\S\"\*410S+jj55r+\"S,\R45\\\)4S\S*\S\4S-jj55r,\"S.\R45\SSSS/\\)4S\S0\!\-S1\!\.S2\!\/S3\0S\S*\S\*4S4jj55r1\"S5\R45\\\)4S\S\S*\S\*4S6jj55r2\"S7\R45\\\)4S8\3S\S*\S\*4S9jj55r4\"S:\R45\SSS\\)4S\S0\!\-S1\!\.S2\!\/S\S*\S\*4S;jj55r5\"S<\R45\SSS\\)4S=\3S>\!\S?\!\/S@\!\6S\S*\SS4SAjj55r7\"SB\R45\\\)4S8\3S>\S\S*\S\*411SCjj55r8\"SD\R45\\\)4S8\3S\S*\S\4SEjj55r9\"SF\R45\\\)4S8\3S\S*\S\:4SGjj55r;\"SH\R45\\\)\<Rz4S8\3SI\>\?S\S*\SJ\<S\@4SKjj55rA\"SL\R45\\\)4S\S\S*\SS4SMjj55rB\"SN\R45\\\)\<Rz4S8\3S\S*\SJ\<S\412SOjj55rC\"SP\R45\SQ\\)4S8\3SR\S\S*\S\D413SSjj55rE\"ST\R45\SSSSS\F\\)4S8\3SU\!\GSV\!\HS \!\S!\!\SW\!\ISX\JS\S*\S\D4SYjj55rK\"SZ\R45\SSSS\\)4S8\3SU\!\GSV\!\HSW\!\IS \!\S\S*\S\L4S[jj55rM\"S\\R�5S]\O\G\!\P\!\Q\!\R\!\S4S^\S\4S_j5rT\"S`\R�5\SSS\\)4SU\GS8\3Sa\PSb\!\QSc\!\RSd\!\SS\S*\S\04Sejj55rU\"Sf\R�5\SSSS\\)4S8\3SU\GSa\!\PSb\!\QSc\!\RSd\!\SS\S*\S\04Sgjj55rV\"Sh\R�5\SSS\\)4S8\3SU\GSa\PSb\!\QSc\!\RSd\!\SS\S*\S\04Sijj55rW\"Sj\R�5\SSQSS\X\\)4S8\3Sk\PSU\!\GSl\SV\!\HSW\!\ISX\JS\S*\S\Y4Smjj55rZ\"Sn\R�5\S\04Soj55r[\"Sp\R45\S\4Sqj55r\\S\]4Srj5r^\"Ss\R45S\4Stj5r_\"Su\R45S\04Svj5r`\"Sw\R45\S\4Sxj55raSyrbU=rc$)|�AsyncFastAPI�@�_clients�systemc�>�[TU]U5 URRS5 URRS5 UR[5UlUR[5UlURUl[R[URR5URRURRURRS9Ulg)N�chroma_server_host�chroma_server_http_port)r@rA�chroma_server_ssl_enabled�default_api_path)�super�__init__�settings�requirer�_opentelemetry_clientr�_product_telemetry_client�	_settingsr;�resolve_url�strr@rArB�chroma_server_api_default_path�_api_url)�selfr>�	__class__s  ��`D:\code\apps\devtools\python\user_packages\Python313\site-packages\chromadb/api/async_fastapi.pyrE�AsyncFastAPI.__init__Ks����
���� ������ 4�5������ 9�:�%)�\�\�2E�%F��"�)-���6L�)M��&������$�0�0�"�6�?�?�#E�#E�F�$*�O�O�$K�$K�&,�o�o�&O�&O�#�_�_�K�K�	1�14��
��returnc��.# �UR5 U$7f�N)�_get_client�rOs rQ�15__aenter__�AsyncFastAPI.__aenter__\s���������s�Nc���# �[UR5S:�aPURR5upUR5IShv�N [UR5S:�aMOggN!7f)Nr)�lenr=�popitem�aclose)rO�_�clients   rQ�_cleanup�AsyncFastAPI._cleanup`sO����$�-�-� �1�$��-�-�/�/�1�K�Q��-�-�/�!�!��$�-�-� �1�$�!�s�A	A/�A-�A/�+A/�exc_type�	exc_value�	tracebackc��@# �UR5IShv�N gN7frV�ra)rOrcrdres    rQ�	__aexit__�AsyncFastAPI.__aexit__es����m�m�o���s���c�T>^�[TT]5 [SU4Sjj5nU"5 g)Nc��B># �TR5IShv�N gN7frVrgrXs�rQ�sync_cleanup�'AsyncFastAPI.stop.<locals>.sync_cleanupls�����-�-�/�!�!�s����rTN)rD�stopr)rOrlrPs` �rQro�AsyncFastAPI.stophs%���
����	�	"�16�	"�	�rSc���Sn[R"5nUR5nXR;a�UR17R=(d 0R5nSUS'S[-S-US'[R"SUUR18R=(d SURS9URU'URU$![a SnN�f=f)	Nrzapplication/jsonzContent-TypezChroma Python Client vz( (https://github.com/chroma-core/chroma)z19User-AgentF)�timeout�headers�verify�limits)
�asyncio�get_event_loop�__hash__�RuntimeErrorr=rJ�chroma_server_headers�copyr
�httpx�AsyncClient�chroma_server_ssl_verify�http_limits)rO�	loop_hash�looprss    rQrW�AsyncFastAPI._get_clientrs����	�	��)�)�+�D��
�
��I��M�M�)��~�~�;�;�A�r�G�G�I�G�&8�G�N�#�(���<�=�
�L�!�(-�'8�'8����~�~�>�>�G�%��'�'�	(�D�M�M�)�$��}�}�Y�'�'��'�	��I�	�s�%C�C"�!C"c�H�[UR5R5$rV)�dictrWrsrXs rQ�get_request_headers� AsyncFastAPI.get_request_headers�s���D�$�$�&�.�.�/�/rSc��UR$rV)rNrXs rQ�get_api_url�AsyncFastAPI.get_api_url�s���}�}�rS�method�path�kwargsc��# �SU;a6[R"URS5[RS9nXCS'[R20R
USSSS9nURU-nUR5R"X40[[U5D6IShv�Nn[R"U5 [R"UR5$N:7f)N�json)�option�content�/)�safe�encoding�errors)�orjson�dumps�pop�OPT_SERIALIZE_NUMPY�urllib�parse�quoterNrW�requestrrr�_raise_chroma_error�loads�text)rOr�r�r��data�escaped_path�url�responses        rQ�
_make_request�AsyncFastAPI._make_request�s�����V���<�<��21�22�6� 2�6�;U�;U�V�D� $�9���|�|�)�)�$�S�4�PT�)�U���m�m�l�*���)�)�+�3�3�F�U�4��V�CT�U�U���*�*�8�4��|�|�H�M�M�*�*�V�s�BC� C�!;CzAsyncFastAPI.heartbeatc��^# �URSS5IShv�Nn[US5$N7f)N�get�znanosecond heartbeat�r��int)rOr�s  rQ�	heartbeat�AsyncFastAPI.heartbeat�s2����+�+�E�2�6�6���8�2�3�4�4�7�s�-�+�-zAsyncFastAPI.create_database�name�tenantc��N# �URSSUS3SU0S9IShv�N gN7f)N�post�	/tenants/�23/databasesr��r��r��rOr�r�s   rQ�create_database�AsyncFastAPI.create_database�s:���� � ����x�z�*��$��!�24�	25�	26�s�%�#�%zAsyncFastAPI.get_databasec��x# �URSSUSU3SU0S9IShv�Nn[USUSUSS9$N7f)	Nr�r��/databases/r���params�idr��r�r�r�)r�r)rOr�r�r�s    rQ�get_database�AsyncFastAPI.get_database�se����+�+����x�{�4�&�1��f�%�,�27�28�����~�H�V�$4�X�h�=O�29�	30�
31�s�:�8�:zAsyncFastAPI.delete_databasec��P# �URSSUSU35IShv�N gN7f)N�deleter�r�r�r�s   rQ�delete_database�AsyncFastAPI.delete_database�s2���� � ����x�{�4�&�1�32�	33�	34�s�&�$�&zAsyncFastAPI.list_databases�limit�offsetc	���# �URSSUS3[R"UUS.5S9IShv�NnUVs/sHn[USUSUSS	9PM sn$N)s snf7f)35Nr�r�r��r�r�r�r�r�r�r�)r�r�
_clean_paramsr)rOr�r�r�r��dbs      rQ�list_databases�AsyncFastAPI.list_databases�s�����+�+����x�z�*�!�/�/�"�$���,�	36�	37���38���
��4��r�&�z�"�X�,�G��39�	40�	41��42�s �0A#�A�A#�A�A#�A#zAsyncFastAPI.create_tenantc��F# �URSSSU0S9IShv�N gN7f)Nr�z/tenantsr�r�r�)rOr�s  rQ�
create_tenant�AsyncFastAPI.create_tenant�s1���� � ����$��!�43�	44�	45�s�!��!zAsyncFastAPI.get_tenantc��`# �URSSU-5IShv�Nn[USS9$N7f)Nr�r�r�)r�)r�r)rOr��	resp_jsons   rQ�46get_tenant�AsyncFastAPI.get_tenant�s>����,�,���$��47�48�	�49�9�V�,�-�-�50�s�.�,�.zAsyncFastAPI.get_user_identityc��T# �[S0URSS5IShv�ND6$N7f)Nr�z/auth/identity�)rr�rXs rQ�get_user_identity�AsyncFastAPI.get_user_identitys)����R�T�%7�%7��?O�%P�P�R�R�P�s�(�&�(zAsyncFastAPI.list_collections�databasec	���# �URSSUSUS3[R"UUS.5S9IShv�NnUVs/sHn[R"U5PM nnU$N,s snf7f)Nr�r�r��/collectionsr�r�)r�rr��CollectionModel�	from_json)rOr�r�r�r�r��json_collection�modelss        rQ�list_collections�AsyncFastAPI.list_collectionss�����,�,����x�{�8�*�L�A�!�/�/�"�$���-�	51�	52�	�OX�53�NW�?�O�%�%�o�6�i�	�54��
�	55��56�s �3A)�A"�A)� A$�A)�$A)zAsyncFastAPI.count_collectionsc��p# �URSSUSUS35IShv�Nn[[U5$N7f)Nr�r�r�z/collections_count)r�rr�)rOr�r�r�s    rQ�count_collections�AsyncFastAPI.count_collections$sF���57�,�,����x�{�8�*�4F�G�58�59�	�60�C��#�#�61�s�6�4�6zAsyncFastAPI.create_collectionF�schema�
configuration�metadata�
get_or_createc62���# �U(a[X45OSnU(aUR5OSn	URSSUSUS3UUUU	US.S9IShv�Nn63[R"U645nU$N7f)zCreates a collectionNr�r�r�r�)r�r�r�r�r�r�)r�serialize_to_jsonr�r�r�)rOr�r�r�r�r�r�r��config_json�serialized_schemar��models            rQ�create_collection�AsyncFastAPI.create_collection0s�����
4�M�L��	�65;A�F�4�4�6�d���,�,����x�{�8�*�L�A��$�!,�+�!.��-�6667�6869�	� �)�)�)�4����7071�s�AA0�A.�A0zAsyncFastAPI.get_collectionc	��# �URSSUSUSU35IShv�Nn[R"U5nU$N7f)Nr�r�r��
/collections/�r�r�r�)rOr�r�r�r�r�s      rQ�get_collection�AsyncFastAPI.get_collectionRsQ����,�,����x�{�8�*�M�$��H�72�73�	�74 �)�)�)�4����75���A�>�Az!AsyncFastAPI.get_collection_by_id�
collection_idc	��# �URSSUSUSU35IShv�Nn[R"U5nU$N7f)zReturns a collection by its IDr�r�r�z/collections/by-id/Nr�)rOr�r�r�r�r�s      rQ�get_collection_by_id�!AsyncFastAPI.get_collection_by_idcsR����,�,����x�{�8�*�4G�
��W�76�77�	�78 �)�)�)�4����79�r�z%AsyncFastAPI.get_or_create_collectionc80��H# �URUUUUSUUS9IShv�N$N7f)NT)r�r�r�r�r�r�r�)r�)rOr�r�r�r�r�r�s       rQ�get_or_create_collection�%AsyncFastAPI.get_or_create_collectionws>����+�+���'�����,�81�82�	83�84�s�"� �"zAsyncFastAPI._modifyr��new_name�new_metadata�new_configurationc	��# �URSSUSUSU3UUU(a[U5OSS.S9IShv�N gN7f)N�putr�r�r�)r�r�r�r�)r�r)rOr�r�r�r�r�r�s       rQ�_modify�AsyncFastAPI._modify�s`���� � ����x�{�8�*�M�"��F� ,�$�%�&M�%�&���!�85�	86�	87�s�4>�<�>zAsyncFastAPI._forkc88��# �URSSUSUSUS3SU0S9IShv�Nn[R"U5nU$N7f)Nr�r�r�r�z/forkr�r�r�)rOr�r�r�r�r�r�s       rQ�_fork�AsyncFastAPI._fork�sa����,�,����x�{�8�*�M�-��PU�V��h�'�-�89�90�	�91 �)�)�)�4����
92�s�!A�A�AzAsyncFastAPI._fork_countc93��r# �URSSUSUSUS35IShv�Nn[US5$N7f)Nr�r�r�r�z/fork_count�countr��rOr�r�r�r�s     rQ�_fork_count�AsyncFastAPI._fork_count�sO����,�,����x�{�8�*�M�-��P[�\�94�95�	��9�W�%�&�&�	96�s� 7�5�7z!AsyncFastAPI._get_indexing_statusc97��# �URSSUSUSUS35IShv�Nn[USUSUSUS	S989$N7f)Nr�r�r�r�z/indexing_status�num_indexed_ops�num_unindexed_ops�	total_ops�op_indexing_progress)rrr
r)r�r'rs     rQ�_get_indexing_status�!AsyncFastAPI._get_indexing_status�so����,�,����x�{�8�*�M�-��P`�a�99�100�	��%�&7�8�'�(;�<���,�!*�+A�!B�	101�	102�	103�s� A�?�AzAsyncFastAPI._search�searches�104read_levelc105��r# �UVs/sHofR5PM snUS.nURSSUSUSUS3US9IShv�NnURS	S5n	U	b<U	V106Vs/sH)n107U108b!U109Vs/sHnUb[U5OSPM snOSPM+ snn110US	'[	U5$s snfNes snfs snn111f7f)112z&Performs hybrid search on a collection)rrr�r�r�r�z/searchr�N�	metadatas)�to_dictr�r�r9r0)rOr�rr�r�r�s�payloadr��metadata_batchesrr�s            rQ�_search�AsyncFastAPI._search�s����/7�7�h�����h�7�$�113��114�,�,����x�{�8�*�M�-��PW�X��-�115�116�	�%�=�=��d�;���'�"2�&�"2�I��(�%.��$-��7?�6J�(��2�PT�T�$-��117��"2�&�I�k�"��I�&�&��-8�118����&�s?�B7�B%�$B7�B*�B7�#
B1�0B,�119	B1�B7�,B1�1B7zAsyncFastAPI.delete_collectionc	��V# �URSSUSUSU35IShv�N gN7f)Nr�r�r�r�r�)rOr�r�r�s    rQ�delete_collection�AsyncFastAPI.delete_collection�s8���� � ����x�{�8�*�M�$��H�120�	121�	122�s�)�'�)zAsyncFastAPI._countc123��# �URSSUSUSUS3SUR0S9IShv�Nn[[U5$N7f)	z0Returns the number of embeddings in the databaser�r�r�r�z/countrr�N)r��valuerr�)rOr�r�r�rr�s      rQ�_count�AsyncFastAPI._counts_����,�,����x�{�8�*�M�-��PV�W� �*�"2�"2�3�-�124�125�	��C��#�#�
126�s�+A�A�AzAsyncFastAPI._peek�127�nc��P# �URUUUU[S9IShv�NnU$N7f)N)r�r�r��include)�_getr7)rOr�r#r�r��resps      rQ�_peek�AsyncFastAPI._peeks:����Y�Y�����6��128�129����130�s�&�$�&zAsyncFastAPI._get�ids�where�where_documentr%c131��# �UV132s/sHo�S:wdM133U134PM nn135URSSUSU	SUS3UUUUUUS.S9IShv�NnURS	S5n
U
b U
Vs/sHnUb[U5OSPM n
n[US136URSS5U
URSS5SURS
S5US9$s sn137fN�s snf7f)Nr�r�r�r�r�z/get)r*r+r�r�r,r%r�rr*�138embeddings�	documents�uris)r*r.rr/r�r0�included)r�r�r9r.)rOr�r*r+r�r�r,r%r�r��i�filtered_includer�rr�s               rQr&�AsyncFastAPI._get1s���(/�>�w�!�v�+�A�w��>��,�,����x�{�8�*�M�-��PT�U���� �"0�+�
�-�139�140�	��M�M�+�t�4�	�� �!*�� )�H�3;�2F�$�X�.�D�P� )�
��141��%� � �}�}�\�4�8���m�m�K��6�����v�t�,��142�	143��-?�144���s3�C	�	B=�B=�'C	�C�C	�C�9A145C	�C	zAsyncFastAPI._deletec146��# �X2US.nUbXXS'URSSUSUSUS3US9IShv�Nn	[U	(aU	RS	S1475S9$S148S9$N(7f)N)r+r*r,r�r�r�r�r�z/deleter��deletedr)r6)r�r"r�)149rOr�r*r+r,r�r�r��bodyr's150          rQ�_delete�AsyncFastAPI._delete`s~��� %�N�S����!��M��'�'����x�{�8�*�M�-��PW�X��(�151�152��153�d�D�H�H�Y��$:�J�J��J�J�154�s�+A�A�)AzAsyncFastAPI._submit_batch�batchr�c��&# �UR5IShv�NnSnUSb#USVs/sHnUb[U5OSPM nnUSU(a[US5OUSUUSUSS.nURSUUS	9IShv�N$Nqs snfN7f)155z/156Submits a batch of embeddings to the database157N�r���)r*r.rr/r0r�r�)�supports_base64_encodingr8r2r�)rOr:r�r@�serialized_metadatasr�r�s       rQ�
_submit_batch�AsyncFastAPI._submit_batchvs����*.�)F�)F�)H�#H� �#����8��!&�a��$� (�H�19�0D�"�8�,�$�N� (�
!�$���8�'�@��a��I��q��-��q���!�H�158���'�'����(�159�160�	161�'$I��$�162�s,�B�B�B�B163�?B�B�B�164BzAsyncFastAPI._addr.rr/r0c	���# �UUUUU4n	[U	SUR5IShv�N05 URU	SUSUS[U5S35IShv�N gN7N7f)N�max_batch_sizer�r�r�z/addT�r3�get_max_batch_sizerBrL)165rOr*r�r.rr/r0r�r�r:s166          rQ�_add�AsyncFastAPI._add�s����
�����167��	�u�/�t�7N�7N�7P�1P�Q�R�� � ����x�{�8�*�M�#�m�BT�AU�UY�Z�168�	169�	170��2Q�	171��!�"A �A�1A �A�A �A zAsyncFastAPI._updatec	���# �UUbUOSUUU4n	[U	SUR5IShv�N05 URU	SUSUS[U5S35IShv�N gN7N7f)NrEr�r�r�z/updateTrF�172rOr�r*r.rr/r0r�r�r:s173          rQ�_update�AsyncFastAPI._update�s����
�$�0�J�d����174��	�u�/�t�7N�7N�7P�1P�Q�R�� � ����x�{�8�*�M�#�m�BT�AU�U\�]�175�	176�	177�178�2Q�	179�s!�'A%�A!�1A%�A#�A%�#A%zAsyncFastAPI._upsertc	���# �UUUUU4n	[U	SUR5IShv�N05 URU	SUSUS[U5S35IShv�N gN7N7f)NrEr�r�r�z/upsertTrFrLs180          rQ�_upsert�AsyncFastAPI._upsert�s����
�����181��	�u�/�t�7N�7N�7P�1P�Q�R�� � ����x�{�8�*�M�#�m�BT�AU�U\�]�182�	183�	184��2Q�	185�rJzAsyncFastAPI._query�query_embeddings�	n_resultsc186��# �UV187s/sHo�S:wdM188U189PM nn190URSSUSU	SUS3UUb[U5OSUUUUS.S9IShv�NnURS	S5n
U
b8U
VVs/sH)nUb!UVs/sHnUb[U5OSPM snOSPM+ n
nn[	US191URSS5URSS5U
URS
S5URSS5SUS9$s sn192fN�s snfs snnf7f)Nr�r�r�r�r�z/query)r*rRrSr+r,r%r�rr*�	distancesr.r/r0)r*rUr.rr/r0r�r1)r�r4r�r9r/)rOr�rRr*rSr+r,r%r�r�r2r3r�rrr�s                rQ�_query�AsyncFastAPI._query�se���(/�>�w�!�v�+�A�w��>��,�,����x�{�8�*�M�-��PV�W��#�/�%B�BR�$S��&��"0�+�	�-�
193�
194�	�%�=�=��d�;���'�"2� �"2�I��(�%.��$-��7?�6J�(��2�PT�T�$-��195��"2�
� ���%� ��m�m�K��6� �}�}�\�4�8�&��m�m�K��6����v�t�,���	196�		197��;?�
198��$�� �sE�D�	C4�C4�5D�C9�D�.
D�;C;�	D�AD�;D�DzAsyncFastAPI.resetc��b# �URSS5IShv�Nn[[U5$N7f)Nr�z/reset)r�r�bool�rOr�s  rQ�reset�AsyncFastAPI.reset(s.����,�,�V�X�>�>�	��D�)�$�$�?���/�-�/zAsyncFastAPI.get_versionc��b# �URSS5IShv�Nn[[U5$N7f)Nr�z/version)r�rrLrZs  rQ�get_version�AsyncFastAPI.get_version.s/����,�,�U�J�?�?�	��C��#�#�@�r]c��UR$rV)rJrXs rQ�get_settings�AsyncFastAPI.get_settings4s���~�~�rSz"AsyncFastAPI.get_pre_flight_checksc��# �URc URSS5IShv�NnXlUR$N7f)Nr�z/pre-flight-checks)�pre_flight_checksr�rZs  rQ�get_pre_flight_checks�"AsyncFastAPI.get_pre_flight_checks8sA����!�!�)�"�0�0��8L�M�M�I�%.�"��%�%�%�N�s�#>�<�>z%AsyncFastAPI.supports_base64_encodingc��# �UR5IShv�Nn[[URSS55nU$N&7f)Nr@F)rfrrYr�)rOre�b64_encoding_enableds   rQr@�%AsyncFastAPI.supports_base64_encodingAsE���#'�"<�"<�">�>��#��#�'�'�(B�E�J� 199��$�#�	?���?�=�'?zAsyncFastAPI.get_max_batch_sizec��# �UR5IShv�Nn[[URSS55nU$N&7f)NrE�����)rfrr�r�)rOrerEs   rQrG�AsyncFastAPI.get_max_batch_sizeKs?���#'�"<�"<�">�>���c�#4�#8�#8�9I�2�#N�O����?�rk)rNrHrIrJre)rTr;rn)d�__name__�200__module__�__qualname__�__firstlineno__r=r201r�r|r}�__annotations__rrErYrarrhrrorWrrLr�r�r�rr�	OPERATIONr�rr�rr�r�rr	r�r�rr�rr�rr�r�r�r(rr1rYr�r�rr�r�rrrrr'rr*�
INDEX_AND_WALrr!r0rrr r.r(r5r%r,r-r&r&r"r8�ALLrr$r)r#r+rBrHrMrPr6r/rVr[r_rrbrfr@rG�__static_attributes__�
__classcell__)rPs@rQr;r;@s����.0�H�d�3��)�)�)�*�/�202�v�203�"�"�204�������PT������(�U�.�.�(�>�0�W�S�#�X�%6�0��0���S����+��+�!$�+�04�S�#�X��+�	�+�$�*�,D�,N�,N�O�
�5��5��P�5��0�2J�2T�2T�U�
�%�	205��	206��	207�208�		209��V�	210��-�/G�/Q�/Q�R�
�%�
211��
212��
213�214�	
215��S�
216��0�2J�2T�2T�U�
�%�217��218��219�220�	221��V�222��/�1I�1S�1S�T�
� $� $�$�	223���}�224���
�225��	226�227228�(�	�229��U�230�,�.�0H�0R�0R�S�
�231��232��233��T�234��+�-E�-O�-O�P�
�.�S�.�V�.��Q�.��2�4L�4V�4V�W�
�S��S��X�S��1�3K�3U�3U�V�
� $� $�$�(����}����
���	�235��236�/�	"�
��W��.�2�4L�4V�4V�W�
�*�<L�$��$�69�$�	�$��X�$��2�4L�4V�4V�W�
�$(�AE�15�#�$�(������ �� � =�>�	�237�-�.���
�����238���X��@�/�1I�1S�1S�T�
�%�(�	
��
��
��	
�239240�
��U�
��+�-E�-O�-O���%�(�	������	�241242����� �/�1I�1S�1S���$(�AE�15�$�(�243��244��� �245� � =�>�	246�247�-�.�248��
249��250�251�252���253�&�(�*B�*L�*L�M�
�#'�59�EI�$�(�254��255��3�-�256��1�2�	257�258$�$A�B�259��
260��261�262�263��N�264�.�&�(@�(J�(J�K�
�265%�(�
��
��
��	
�266�
�267�

��L�
��,�.F�.P�.P�Q�
�%�(�	268'��269'��270'��	271'�272273
�274'��R�275'��+�-E�-O�-O���%�(�	276��277��278��	279�280281�282���283�"�(�*B�*L�*L�M�
�284%�(� )� 7� 7�
 '�� '��v�,� '��	 '�285� '��
 '�286� '��N� '�D�2�4L�4V�4V�W�
�%�(�		287��	288��	289��		290�291292�	293��X�	294��'�)A�)K�)K�L�
�%�(� )� 7� 7�$��$��$��	$�295�$�296
�
$��M�$� �&�(@�(J�(J�K�
��$�(�������	�297��298�
��L��"�%�'?�'I�'I�J�
�"�!%�#� $�26�3�$�(�+299��+300��c�]�+301����	+302�303��}�+304���
�
+305�!��/�+306��+307��+308��+309�310�+311��K�+312�Z�(�*B�*L�*L�M�
�"�!%�26�#�$�(�K��K��c�]�K����	K�313!��/�K���}�
K��K��K�314�K��N�K�(�.�0H�0L�0L�M�%315����Z� ��Y���Y���T�N�	
�316�%317��%318�319
�%320�N�%321�N�%�'?�'C�'C�D�
�*.�)-�#�$�(��
�����	�322�I�&���I�&�
��t�n������323���E��2�(�*B�*F�*F�G�
�324,0�)-�)-�#�$�(�������Z�(�	�325�I�&���I�&�
��t�n������326���H��6�(�*B�*F�*F�G�
�*.�)-�#�$�(�������	�327�I�&���I�&�
��t�n������328���H��2�'�)A�)E�)E�F�
�329"��!%�26�<�$�(�3330��3331�%�3332��c�]�	3333�334�3335����
3336�!��/�3337��3338��3339��3340�341�3342��G�3343�j�&�(@�(D�(D�E�
�%�T�%��F�%��,�.F�.P�.P�Q�
�$�3�$��R�$���h�����,�.F�.P�.P��&�S�&��&��/�1I�1S�1S��$��$��$��3�5M�5W�5W�X�
��#���Y�rSr;)Qrv�uuidr�urllib.parser�r��typingrrrrrr	r344r�loggingr|�	overridesr�chromadbr
�
chromadb.authr�chromadb.api.async_apir�chromadb.api.base_http_clientr�%chromadb.api.collection_configurationrrrr�chromadb.configrrrr� chromadb.telemetry.opentelemetryrrr�chromadb.telemetry.productr�chromadb.utils.async_to_syncr�chromadb.typesrrr r��"chromadb.execution.expression.planr!�chromadb.api.typesr"r#r$r%r&r'r(r)r*r+r,r-r.r/r0r1r2r3r4r5r6r7r8r9�	getLoggerro�loggerr;r�rSrQ�<module>r�s������
�L�L�L���� �&�1�8���O�N���345>�6�J�J�5�������0��346�	�	�8�	$��P�>�>�PrS
codekingpro/portable-devtools · Team Ai