§
    ˜Štj9n  ã                   óÈ  — d dl Z d dlmZ d dlZd dlZd dlmZmZm	Z	m
Z
mZmZmZmZ d dlZd dlZd dlmZ d dlmZ d dlmZ d dlmZ d dlmZ d d	lmZmZmZmZ d d
l m!Z!m"Z"m#Z#m$Z$ d dl%m&Z&m'Z'm(Z( d dl)m*Z* d dl+m,Z, d dl-m.Z.m/Z/m0Z1 d dl2m3Z3 d dl4m5Z5m6Z6m7Z7m8Z8m9Z9m:Z:m;Z;m<Z<m=Z=m>Z>m?Z?m@Z@mAZAmBZBmCZCmDZDmEZEmFZFmGZGmHZHmIZI d dl4mJZJmKZKmLZL  ejM        eN¦  «        ZO G d„ dee¦  «        ZPdS )é    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)ÚDeleteResultÚ	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                   ó²  ‡ — e Zd ZU i Zeeej        f         ed<   de	fˆ fd„Z
dxd„Zdyd„Zded	ed
eddfd„Zedyˆ fd„¦   «         Zdej        fd„Zedeeef         fd„¦   «         Zedefd„¦   «         Zdededeeef         defd„Z edej        ¦  «        edefd„¦   «         ¦   «         Z edej        ¦  «        eefdededdfd„¦   «         ¦   «         Z edej        ¦  «        eefdededefd„¦   «         ¦   «         Z edej        ¦  «        eefdededdfd„¦   «         ¦   «         Z edej        ¦  «        eddefde e         d e e         dede!e         fd!„¦   «         ¦   «         Z" ed"ej        ¦  «        ededdfd#„¦   «         ¦   «         Z# ed$ej        ¦  «        edede$fd%„¦   «         ¦   «         Z% ed&ej        ¦  «        ede&fd'„¦   «         ¦   «         Z' ed(ej        ¦  «        eddee(fde e         d e e         ded)ede!e)         f
d*„¦   «         ¦   «         Z* ed+ej        ¦  «        eee(fded)edefd,„¦   «         ¦   «         Z+ ed-ej        ¦  «        edddd.ee(fded/e e,         d0e e-         d1e e.         d2e/ded)ede)fd3„¦   «         ¦   «         Z0 ed4ej        ¦  «        eee(fdeded)ede)fd5„¦   «         ¦   «         Z1 ed6ej        ¦  «        eee(fd7e2ded)ede)fd8„¦   «         ¦   «         Z3 ed9ej        ¦  «        edddee(fded/e e,         d0e e-         d1e e.         ded)ede)fd:„¦   «         ¦   «         Z4 ed;ej        ¦  «        edddee(fd<e2d=e e         d>e e.         d?e e5         ded)eddfd@„¦   «         ¦   «         Z6 edAej        ¦  «        eee(fd7e2d=eded)ede)f
dB„¦   «         ¦   «         Z7 edCej        ¦  «        eee(fd7e2ded)edefdD„¦   «         ¦   «         Z8 edEej        ¦  «        eee(fd7e2ded)ede9fdF„¦   «         ¦   «         Z: edGej        ¦  «        eee(e;j<        fd7e2dHe=e>         ded)edIe;de?fdJ„¦   «         ¦   «         Z@ edKej        ¦  «        eee(fdeded)eddfdL„¦   «         ¦   «         ZA edMej        ¦  «        eee(e;j<        fd7e2ded)edIe;def
dN„¦   «         ¦   «         ZB edOej        ¦  «        edPee(fd7e2dQeded)edeCf
dR„¦   «         ¦   «         ZD edSej        ¦  «        edddddeEee(fd7e2dTe eF         dUe eG         de e         d e e         dVe eH         dWeIded)edeCfdX„¦   «         ¦   «         ZJ edYej        ¦  «        eddddee(fd7e2dTe eF         dUe eG         dVe eH         de e         ded)edeKfdZ„¦   «         ¦   «         ZL ed[ejM        ¦  «        d\eNeFe eO         e eP         e eQ         e eR         f         d]edefd^„¦   «         ZS ed_ejM        ¦  «        edddee(fdTeFd7e2d`eOdae eP         dbe eQ         dce eR         ded)ede/fdd„¦   «         ¦   «         ZT edeejM        ¦  «        eddddee(fd7e2dTeFd`e eO         dae eP         dbe eQ         dce eR         ded)ede/fdf„¦   «         ¦   «         ZU edgejM        ¦  «        edddee(fd7e2dTeFd`eOdae eP         dbe eQ         dce eR         ded)ede/fdh„¦   «         ¦   «         ZV ediejM        ¦  «        eddPddeWee(fd7e2djeOdTe eF         dkedUe eG         dVe eH         dWeIded)edeXfdl„¦   «         ¦   «         ZY edmejM        ¦  «        ede/fdn„¦   «         ¦   «         ZZ edoej        ¦  «        edefdp„¦   «         ¦   «         Z[ede\fdq„¦   «         Z] edrej        ¦  «        defds„¦   «         Z^ edtej        ¦  «        de/fdu„¦   «         Z_ edvej        ¦  «        edefdw„¦   «         ¦   «         Z`ˆ xZaS )zÚAsyncFastAPIÚ_clientsÚsystemc                 óö  •— t          ¦   «                              |¦  «         |j                             d¦  «         |j                             d¦  «         |                      t          ¦  «        | _        |                      t          ¦  «        | _        |j        | _        t           
                    t          |j        j        ¦  «        |j        j        |j        j        |j        j        ¬¦  «        | _        d S )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     €úX/var/www/html/CA-Chatbot/venv/lib/python3.11/site-packages/chromadb/api/async_fastapi.pyrD   zAsyncFastAPI.__init__K   sÄ   ø€ Ý‰Œ×Ò˜Ñ Ô Ð àŒ×ÒÐ 4Ñ5Ô5Ð5ØŒ×ÒÐ 9Ñ:Ô:Ð:à%)§\¢\Õ2EÑ%FÔ%FˆÔ"Ø)-¯ªÕ6LÑ)MÔ)MˆÔ&ØœˆŒå$×0Ò0Ý" 6¤?Ô#EÑFÔFØ$*¤OÔ$KØ&,¤oÔ&OØ#œ_ÔKð	 1ñ 
ô 
ˆŒˆˆó    Úreturnc              ƒ   ó2   K  — |                       ¦   «          | S ©N)Ú_get_client©rN   s    rP   Ú
__aenter__zAsyncFastAPI.__aenter__\   s   è è € Ø×ÒÑÔÐØˆrQ   Nc              ƒ   óÚ   K  — t          | j        ¦  «        dk    rP| j                             ¦   «         \  }}|                     ¦   «         ƒ d {V —† t          | j        ¦  «        dk    °Nd S d S )Nr   )Úlenr<   ÚpopitemÚaclose)rN   Ú_Úclients      rP   Ú_cleanupzAsyncFastAPI._cleanup`   su   è è € Ý�$”-Ñ Ô  1Ò$Ð$Øœ-×/Ò/Ñ1Ô1‰KˆQ�Ø—-’-‘/”/Ð!Ð!Ð!Ð!Ð!Ð!Ð!õ �$”-Ñ Ô  1Ò$Ð$Ð$Ð$Ð$Ð$rQ   Úexc_typeÚ	exc_valueÚ	tracebackc              ƒ   ó>   K  — |                       ¦   «         ƒ d {V —† d S rT   ©r^   )rN   r_   r`   ra   s       rP   Ú	__aexit__zAsyncFastAPI.__aexit__e   s,   è è € Ø�mŠm‰oŒoÐÐÐÐÐÐÐÐÐrQ   c                 ó„   •‡ — t          ¦   «                              ¦   «          t          dˆ fd„¦   «         } |¦   «          d S )NrR   c               “   ó@   •K  — ‰                       ¦   «         ƒ d {V —† d S rT   rc   rV   s   €rP   Úsync_cleanupz'AsyncFastAPI.stop.<locals>.sync_cleanupl   s-   øè è € à—-’-‘/”/Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!Ð!rQ   ©rR   N)rC   Ústopr   )rN   rg   rO   s   ` €rP   ri   zAsyncFastAPI.stoph   sN   øø€ å‰Œ�Š‰Œˆå	ð	"ð 	"ð 	"ð 	"ð 	"ñ 
Œð	"ð 	ˆ‰ŒˆˆˆrQ   c                 ót  — d }	 t          j        ¦   «         }|                     ¦   «         }n# t          $ r d}Y nw xY w|| j        vrf| j        j        pi                      ¦   «         }d|d<   dt          z   dz   |d<   t          j
        d || j        j        pd| j        ¬¦  «        | j        |<   | j        |         S )	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Úlooprl   s       rP   rU   zAsyncFastAPI._get_clientr   sè   € ð ˆ	ð	ÝÔ)Ñ+Ô+ˆDØŸš™œˆIˆIøÝð 	ð 	ð 	ØˆIˆIˆIð	øøøð ˜DœMÐ)Ð)Ø”~Ô;ÐA¸r×GÒGÑIÔIˆGØ&8ˆG�NÑ#à(Ýñà<ñ=ð �LÑ!õ (-Ô'8ØØØ”~Ô>ÐGÀ%ØÔ'ð	(ñ (ô (ˆDŒM˜)Ñ$ð Œ}˜YÔ'Ð's   „', ¬;º;c                 óN   — t          |                      ¦   «         j        ¦  «        S rT   )ÚdictrU   rl   rV   s    rP   Úget_request_headersz AsyncFastAPI.get_request_headers‘   s   € å�D×$Ò$Ñ&Ô&Ô.Ñ/Ô/Ð/rQ   c                 ó   — | j         S rT   )rM   rV   s    rP   Úget_api_urlzAsyncFastAPI.get_api_url•   s
   € àŒ}ÐrQ   ÚmethodÚpathÚkwargsc              ‹   ó¦  K  — d|v r8t          j        |                     d¦  «        t           j        ¬¦  «        }||d<   t          j                             |dd d ¬¦  «        }| j        |z   } |                      ¦   «         j	        ||fi t          t          |¦  «        ¤Žƒ d {V —†}t          j        |¦  «         t          j        |j        ¦  «        S )NÚjson)ÚoptionÚcontentú/)ÚsafeÚencodingÚerrors)ÚorjsonÚdumpsÚpopÚOPT_SERIALIZE_NUMPYÚurllibÚparseÚquoterM   rU   Úrequestr   r   r   Ú_raise_chroma_errorÚloadsÚtext)rN   r€   r�   r‚   ÚdataÚescaped_pathÚurlÚresponses           rP   Ú_make_requestzAsyncFastAPI._make_request™   sÔ   è è € ð �VÐÐÝ”< §
¢
¨6Ñ 2Ô 2½6Ô;UÐVÑVÔVˆDØ $ˆF�9Ñõ ”|×)Ò)¨$°SÀ4ÐPTÐ)ÑUÔUˆØŒm˜lÑ*ˆà3˜×)Ò)Ñ+Ô+Ô3°F¸CÐUÐUÅ4ÍÈVÑCTÔCTÐUÐUÐUÐUÐUÐUÐUÐUˆÝÔ*¨8Ñ4Ô4Ð4ÝŒ|˜HœMÑ*Ô*Ð*rQ   zAsyncFastAPI.heartbeatc              ƒ   óh   K  — |                       dd¦  «        ƒ d {V —†}t          |d         ¦  «        S )NÚgetÚ znanosecond heartbeat©rš   Úint)rN   r™   s     rP   Ú	heartbeatzAsyncFastAPI.heartbeat«   sC   è è € ð ×+Ò+¨E°2Ñ6Ô6Ð6Ð6Ð6Ð6Ð6Ð6ˆÝ�8Ð2Ô3Ñ4Ô4Ð4rQ   zAsyncFastAPI.create_databaseÚnameÚtenantc              ƒ   óR   K  — |                       dd|› d�d|i¬¦  «        ƒ d {V —† d S )NÚpostú	/tenants/ú
/databasesr¡   ©r„   ©rš   ©rN   r¡   r¢   s      rP   Úcreate_databasezAsyncFastAPI.create_database±   se   è è € ð × Ò ØØ*˜Ð*Ð*Ð*Ø˜$�ð !ñ 
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
rQ   zAsyncFastAPI.get_databasec              ƒ   óš   K  — |                       dd|› d|› �d|i¬¦  «        ƒ d {V —†}t          |d         |d         |d         ¬¦  «        S )	Nrœ   r¥   ú/databases/r¢   ©ÚparamsÚidr¡   ©r¯   r¡   r¢   )rš   r   )rN   r¡   r¢   r™   s       rP   Úget_databasezAsyncFastAPI.get_database¾   sŒ   è è € ð ×+Ò+ØØ1˜Ð1Ð1¨4Ð1Ð1Ø˜fÐ%ð ,ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆõ Ø˜Œ~ H¨VÔ$4¸XÀhÔ=Oð
ñ 
ô 
ð 	
rQ   zAsyncFastAPI.delete_databasec              ƒ   óN   K  — |                       dd|› d|› �¦  «        ƒ d {V —† d S )NÚdeleter¥   r¬   r¨   r©   s      rP   Údelete_databasezAsyncFastAPI.delete_databaseÏ   s^   è è € ð × Ò ØØ1˜Ð1Ð1¨4Ð1Ð1ñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
rQ   zAsyncFastAPI.list_databasesÚlimitÚoffsetc           	   ƒ   óŒ   K  — |                       dd|› d�t          j        ||dœ¦  «        ¬¦  «        ƒ d {V —†}d„ |D ¦   «         S )Nrœ   r¥   r¦   ©rµ   r¶   r­   c                 óV   — g | ]&}t          |d          |d         |d         ¬¦  «        ‘Œ'S )r¯   r¡   r¢   r°   )r   )Ú.0Údbs     rP   ú
<listcomp>z/AsyncFastAPI.list_databases.<locals>.<listcomp>î   sC   € ð 
ð 
ð 
àõ ˜˜4œ r¨&¤z¸"¸X¼,ÐGÑGÔGð
ð 
ð 
rQ   ©rš   r   Ú_clean_params)rN   rµ   r¶   r¢   r™   s        rP   Úlist_databaseszAsyncFastAPI.list_databasesÛ   s’   è è € ð ×+Ò+ØØ*˜Ð*Ð*Ð*Ý!Ô/à"Ø$ðð ñô ð ,ñ 	
ô 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ˆð
ð 
àð
ñ 
ô 
ð 	
rQ   zAsyncFastAPI.create_tenantc              ƒ   óJ   K  — |                       ddd|i¬¦  «        ƒ d {V —† d S )Nr¤   z/tenantsr¡   r§   r¨   )rN   r¡   s     rP   Úcreate_tenantzAsyncFastAPI.create_tenantó   sZ   è è € ð × Ò ØØØ˜$�ð !ñ 
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
rQ   zAsyncFastAPI.get_tenantc              ƒ   óp   K  — |                       dd|z   ¦  «        ƒ d {V —†}t          |d         ¬¦  «        S )Nrœ   r¥   r¡   )r¡   )rš   r   )rN   r¡   Ú	resp_jsons      rP   Ú
get_tenantzAsyncFastAPI.get_tenantü   s^   è è € ð ×,Ò,ØØ˜$Ññ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ
 ˜9 VÔ,Ð-Ñ-Ô-Ð-rQ   zAsyncFastAPI.get_user_identityc              ƒ   óR   K  — t          di |                      dd¦  «        ƒ d {V —†¤ŽS )Nrœ   z/auth/identity© )r   rš   rV   s    rP   Úget_user_identityzAsyncFastAPI.get_user_identity  s?   è è € õ ÐRÐR T×%7Ò%7¸Ð?OÑ%PÔ%PÐPÐPÐPÐPÐPÐPÐRÐRÐRrQ   zAsyncFastAPI.list_collectionsÚdatabasec           	   ƒ   ó–   K  — |                       dd|› d|› d�t          j        ||dœ¦  «        ¬¦  «        ƒ d {V —†}d„ |D ¦   «         }|S )Nrœ   r¥   r¬   ú/collectionsr¸   r­   c                 ó6   — g | ]}t          j        |¦  «        ‘ŒS rÆ   )ÚCollectionModelÚ	from_json)rº   Újson_collections     rP   r¼   z1AsyncFastAPI.list_collections.<locals>.<listcomp>  s0   € ð 
ð 
ð 
Ø;J�OÔ% oÑ6Ô6ð
ð 
ð 
rQ   r½   )rN   rµ   r¶   r¢   rÈ   rÃ   Úmodelss          rP   Úlist_collectionszAsyncFastAPI.list_collections  sž   è è € ð ×,Ò,ØØA˜ÐAÐA¨8ÐAÐAÐAÝ!Ô/à"Ø$ðð ñô ð -ñ 	
ô 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ˆ	ð
ð 
ØNWð
ñ 
ô 
ˆð ˆrQ   zAsyncFastAPI.count_collectionsc              ƒ   óv   K  — |                       dd|› d|› d�¦  «        ƒ d {V —†}t          t          |¦  «        S )Nrœ   r¥   r¬   z/collections_count)rš   r   rŸ   )rN   r¢   rÈ   rÃ   s       rP   Úcount_collectionszAsyncFastAPI.count_collections$  sf   è è € ð
 ×,Ò,ØØG˜ÐGÐG¨8ÐGÐGÐGñ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ
 •C˜Ñ#Ô#Ð#rQ   zAsyncFastAPI.create_collectionFÚschemaÚconfigurationÚmetadataÚget_or_createc           
   ƒ   óà   K  — |rt          ||¦  «        nd}|r|                     ¦   «         nd}	|                      dd|› d|› d�||||	|dœ¬¦  «        ƒ d{V —†}
t          j        |
¦  «        }|S )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_collectionzAsyncFastAPI.create_collection0  sÈ   è è € ð ðÕ3°MÀ8ÑLÔLÐLàð 	ð
 ;AÐJ˜F×4Ò4Ñ6Ô6Ð6ÀdÐØ×,Ò,ØØA˜ÐAÐA¨8ÐAÐAÐAàØ$Ø!,Ø+Ø!.ðð ð -ñ 

ô 

ð 

ð 

ð 

ð 

ð 

ð 

ˆ	õ  Ô)¨)Ñ4Ô4ˆàˆrQ   zAsyncFastAPI.get_collectionc           	   ƒ   ó|   K  — |                       dd|› d|› d|› �¦  «        ƒ d {V —†}t          j        |¦  «        }|S )Nrœ   r¥   r¬   ú/collections/©rš   rÌ   rÍ   )rN   r¡   r¢   rÈ   rÃ   rÛ   s         rP   Úget_collectionzAsyncFastAPI.get_collectionR  sp   è è € ð ×,Ò,ØØH˜ÐHÐH¨8ÐHÐHÀ$ÐHÐHñ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ
  Ô)¨)Ñ4Ô4ˆàˆrQ   z!AsyncFastAPI.get_collection_by_idÚcollection_idc           	   ƒ   ó|   K  — |                       dd|› d|› d|› �¦  «        ƒ d{V —†}t          j        |¦  «        }|S )zReturns a collection by its IDrœ   r¥   r¬   z/collections/by-id/Nrß   )rN   rá   r¢   rÈ   rÃ   rÛ   s         rP   Úget_collection_by_idz!AsyncFastAPI.get_collection_by_idc  sp   è è € ð ×,Ò,ØØW˜ÐWÐW¨8ÐWÐWÈÐWÐWñ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ
  Ô)¨)Ñ4Ô4ˆàˆrQ   z%AsyncFastAPI.get_or_create_collectionc           	   ƒ   óJ   K  — |                       ||||d||¬¦  «        ƒ d {V —†S )NT)r¡   rÓ   rÔ   rÕ   rÖ   r¢   rÈ   )rÜ   )rN   r¡   rÓ   rÔ   rÕ   r¢   rÈ   s          rP   Úget_or_create_collectionz%AsyncFastAPI.get_or_create_collectionw  sX   è è € ð ×+Ò+ØØØ'ØØØØð ,ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
rQ   zAsyncFastAPI._modifyr¯   Únew_nameÚnew_metadataÚnew_configurationc           	   ƒ   ó‚   K  — |                       dd|› d|› d|› �|||rt          |¦  «        nd dœ¬¦  «        ƒ d {V —† d S )NÚputr¥   r¬   rÞ   )rç   ræ   rè   r§   )rš   r   )rN   r¯   ræ   rç   rè   r¢   rÈ   s          rP   Ú_modifyzAsyncFastAPI._modifyŽ  sŸ   è è € ð × Ò ØØF˜ÐFÐF¨8ÐFÐFÀ"ÐFÐFà ,Ø$ð %ð&Õ%LØ%ñ&ô &ð &ð ðð ð !ñ 
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
rQ   zAsyncFastAPI._forkc           
   ƒ   ó†   K  — |                       dd|› d|› d|› d�d|i¬¦  «        ƒ d {V —†}t          j        |¦  «        }|S )Nr¤   r¥   r¬   rÞ   z/forkræ   r§   rß   )rN   rá   ræ   r¢   rÈ   rÃ   rÛ   s          rP   Ú_forkzAsyncFastAPI._fork§  s€   è è € ð ×,Ò,ØØV˜ÐVÐV¨8ÐVÐVÀ-ÐVÐVÐVØ˜hÐ'ð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ
  Ô)¨)Ñ4Ô4ˆØˆrQ   zAsyncFastAPI._fork_countc           
   ƒ   ó|   K  — |                       dd|› d|› d|› d�¦  «        ƒ d {V —†}t          |d         ¦  «        S )Nrœ   r¥   r¬   rÞ   z/fork_countÚcountrž   ©rN   rá   r¢   rÈ   rÃ   s        rP   Ú_fork_countzAsyncFastAPI._fork_count¸  sq   è è € ð ×,Ò,ØØ\˜Ð\Ð\¨8Ð\Ð\À-Ð\Ð\Ð\ñ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ �9˜WÔ%Ñ&Ô&Ð&rQ   z!AsyncFastAPI._get_indexing_statusc           
   ƒ   ó¨   K  — |                       dd|› d|› d|› d�¦  «        ƒ d {V —†}t          |d         |d         |d         |d	         ¬
¦  «        S )Nrœ   r¥   r¬   rÞ   z/indexing_statusÚnum_indexed_opsÚnum_unindexed_opsÚ	total_opsÚop_indexing_progress)ró   rô   rõ   rö   )rš   r'   rð   s        rP   Ú_get_indexing_statusz!AsyncFastAPI._get_indexing_statusÆ  s˜   è è € ð ×,Ò,ØØa˜ÐaÐa¨8ÐaÐaÀ-ÐaÐaÐañ
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ Ø%Ð&7Ô8Ø'Ð(;Ô<Ø Ô,Ø!*Ð+AÔ!Bð	
ñ 
ô 
ð 	
rQ   zAsyncFastAPI._searchÚsearchesÚ
read_levelc           
   ƒ   óà   K  — d„ |D ¦   «         |dœ}|                       dd|› d|› d|› d�|¬¦  «        ƒ d	{V —†}|                     d
d	¦  «        }|�d„ |D ¦   «         |d
<   t          |¦  «        S )z&Performs hybrid search on a collectionc                 ó6   — g | ]}|                      ¦   «         ‘ŒS rÆ   )Úto_dict)rº   Úss     rP   r¼   z(AsyncFastAPI._search.<locals>.<listcomp>ç  s    € Ð7Ð7Ð7¨˜Ÿš™œÐ7Ð7Ð7rQ   )rø   rù   r¤   r¥   r¬   rÞ   z/searchr§   NÚ	metadatasc                 ó.   — g | ]}|�d„ |D ¦   «         nd ‘ŒS )Nc                 ó4   — g | ]}|�t          |¦  «        nd ‘ŒS rT   ©r9   ©rº   rÕ   s     rP   r¼   z3AsyncFastAPI._search.<locals>.<listcomp>.<listcomp>ô  ó<   € ð ð ð à ð 7?Ð6JÕ(¨Ñ2Ô2Ð2ÐPTðð ð rQ   rÆ   ©rº   rþ   s     rP   r¼   z(AsyncFastAPI._search.<locals>.<listcomp>ó  sS   € ð &ð &ð &ð ð Ð(ð	ð à$-ðñ ô ð ð
 ð&ð &ð &rQ   )rš   rœ   r0   )	rN   rá   rø   r¢   rÈ   rù   ÚpayloadrÃ   Úmetadata_batchess	            rP   Ú_searchzAsyncFastAPI._searchÛ  s×   è è € ð 8Ð7¨hÐ7Ñ7Ô7Ø$ð
ð 
ˆð
 ×,Ò,ØØX˜ÐXÐX¨8ÐXÐXÀ-ÐXÐXÐXØð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	ð %Ÿ=š=¨°dÑ;Ô;ÐØÐ'ð&ð &ð "2ð&ñ &ô &ˆI�kÑ"õ ˜IÑ&Ô&Ð&rQ   zAsyncFastAPI.delete_collectionc           	   ƒ   óT   K  — |                       dd|› d|› d|› �¦  «        ƒ d {V —† d S )Nr³   r¥   r¬   rÞ   r¨   )rN   r¡   r¢   rÈ   s       rP   Údelete_collectionzAsyncFastAPI.delete_collectionÿ  sf   è è € ð × Ò ØØH˜ÐHÐH¨8ÐHÐHÀ$ÐHÐHñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
rQ   zAsyncFastAPI._countc           
   ƒ   óŽ   K  — |                       dd|› d|› d|› d�d|j        i¬¦  «        ƒ d{V —†}t          t          |¦  «        S )	z0Returns the number of embeddings in the databaserœ   r¥   r¬   rÞ   z/countrù   r­   N)rš   Úvaluer   rŸ   )rN   rá   r¢   rÈ   rù   rÃ   s         rP   Ú_countzAsyncFastAPI._count  s~   è è € ð ×,Ò,ØØW˜ÐWÐW¨8ÐWÐWÀ-ÐWÐWÐWØ  *Ô"2Ð3ð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	õ •C˜Ñ#Ô#Ð#rQ   zAsyncFastAPI._peeké
   Únc              ƒ   óT   K  — |                       ||||t          ¬¦  «        ƒ d {V —†}|S )N)r¢   rÈ   rµ   Úinclude)Ú_getr7   )rN   rá   r  r¢   rÈ   Úresps         rP   Ú_peekzAsyncFastAPI._peek  sT   è è € ð —Y’YØØØØÝ6ð ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆð ˆrQ   zAsyncFastAPI._getÚidsÚwhereÚwhere_documentr  c
              ƒ   ót  K  — d„ |D ¦   «         }
|                       dd|› d|	› d|› d�||||||
dœ¬¦  «        ƒ d {V —†}|                     d	d ¦  «        }|�d
„ |D ¦   «         }t          |d         |                     dd ¦  «        ||                     dd ¦  «        d |                     dd ¦  «        |¬¦  «        S )Nc                 ó   — g | ]
}|d k    ¯|‘ŒS ©r–   rÆ   ©rº   Úis     rP   r¼   z%AsyncFastAPI._get.<locals>.<listcomp>@  ó   € Ð>Ð>Ð> !°!°v²+°+˜A°+°+°+rQ   r¤   r¥   r¬   rÞ   z/get)r  r  rµ   r¶   r  r  r§   rþ   c                 ó4   — g | ]}|�t          |¦  «        nd ‘ŒS rT   r  r  s     rP   r¼   z%AsyncFastAPI._get.<locals>.<listcomp>Q  s;   € ð ð ð àð 3;Ð2FÕ$ XÑ.Ô.Ð.ÈDðð ð rQ   r  Ú
embeddingsÚ	documentsÚuris)r  r  rþ   r  r–   r   Úincluded)rš   rœ   r.   )rN   rá   r  r  rµ   r¶   r  r  r¢   rÈ   Úfiltered_includerÃ   rþ   s                rP   r  zAsyncFastAPI._get1  s'  è è € ð ?Ð> wÐ>Ñ>Ô>Ðà×,Ò,ØØU˜ÐUÐU¨8ÐUÐUÀ-ÐUÐUÐUàØØØ Ø"0Ø+ðð ð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	ð —M’M +¨tÑ4Ô4ˆ	ØÐ ðð à )ðñ ô ˆIõ
 Ø˜%Ô Ø —}’} \°4Ñ8Ô8ØØ—m’m K°Ñ6Ô6ØØ—’˜v tÑ,Ô,Øð
ñ 
ô 
ð 	
rQ   zAsyncFastAPI._deletec           
   ƒ   óÀ   K  — |||dœ}|�||d<   |                       dd|› d|› d|› d�|¬¦  «        ƒ d {V —†}	t          |	r|	                     d	d
¦  «        nd
¬¦  «        S )N)r  r  r  rµ   r¤   r¥   r¬   rÞ   z/deleter§   Údeletedr   )r$  )rš   r"   rœ   )
rN   rá   r  r  r  rµ   r¢   rÈ   Úbodyr  s
             rP   Ú_deletezAsyncFastAPI._delete`  s­   è è € ð  %¨SÀNÐSÐSˆØÐØ!ˆD�‰MØ×'Ò'ØØX˜ÐXÐX¨8ÐXÐXÀ-ÐXÐXÐXØð (ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆõ
 ¸dÐ$I D§H¢H¨Y¸Ñ$:Ô$:Ð$:ÈÐJÑJÔJÐJrQ   zAsyncFastAPI._submit_batchÚbatchr˜   c              ƒ   ó  K  — |                       ¦   «         ƒ d{V —†}d}|d         �d„ |d         D ¦   «         }|d         |rt          |d         ¦  «        n|d         ||d         |d         dœ}|                      d	||¬
¦  «        ƒ d{V —†S )z?
        Submits a batch of embeddings to the database
        Né   c                 ó4   — g | ]}|�t          |¦  «        nd ‘ŒS rT   )r8   r  s     rP   r¼   z.AsyncFastAPI._submit_batch.<locals>.<listcomp>‰  s;   € ð $ð $ð $àð 19Ð0DÕ" 8Ñ,Ô,Ð,È$ð$ð $ð $rQ   r   é   é   é   )r  r  rþ   r  r   r¤   r§   )Úsupports_base64_encodingr2   rš   )rN   r'  r˜   r.  Úserialized_metadatasr–   s         rP   Ú_submit_batchzAsyncFastAPI._submit_batchv  sì   è è € ð *.×)FÒ)FÑ)HÔ)HÐ#HÐ#HÐ#HÐ#HÐ#HÐ#HÐ à#ÐØ�Œ8Ðð$ð $à % a¤ð$ñ $ô $Ð ð ˜”8à'ðÕ?ÀÀaÄÑIÔIÐIà�q”Ø-Ø˜qœØ˜!”Hð
ð 
ˆð ×'Ò'ØØØð (ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ð 	
rQ   zAsyncFastAPI._addr  rþ   r  r   c	              ƒ   óÒ   K  — |||||f}	t          |	d|                      ¦   «         ƒ d {V —†i¦  «         |                      |	d|› d|› dt          |¦  «        › d�¦  «        ƒ d {V —† dS )NÚmax_batch_sizer¥   r¬   rÞ   z/addT©r3   Úget_max_batch_sizer0  rK   )
rN   r  rá   r  rþ   r  r   r¢   rÈ   r'  s
             rP   Ú_addzAsyncFastAPI._addž  sº   è è € ð ØØØØð
ˆõ 	�uÐ/°t×7NÒ7NÑ7PÔ7PÐ1PÐ1PÐ1PÐ1PÐ1PÐ1PÐQÑRÔRÐRØ× Ò ØØZ˜ÐZÐZ¨8ÐZÐZÅ#ÀmÑBTÔBTÐZÐZÐZñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð ˆtrQ   zAsyncFastAPI._updatec	              ƒ   óÚ   K  — ||�|nd |||f}	t          |	d|                      ¦   «         ƒ d {V —†i¦  «         |                      |	d|› d|› dt          |¦  «        › d�¦  «        ƒ d {V —† dS )Nr2  r¥   r¬   rÞ   z/updateTr3  ©
rN   rá   r  r  rþ   r  r   r¢   rÈ   r'  s
             rP   Ú_updatezAsyncFastAPI._update¹  sÃ   è è € ð Ø$Ð0ˆJˆJ°dØØØð
ˆõ 	�uÐ/°t×7NÒ7NÑ7PÔ7PÐ1PÐ1PÐ1PÐ1PÐ1PÐ1PÐQÑRÔRÐRà× Ò ØØ]˜Ð]Ð]¨8Ð]Ð]Å#ÀmÑBTÔBTÐ]Ð]Ð]ñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð
 ˆtrQ   zAsyncFastAPI._upsertc	              ƒ   óÒ   K  — |||||f}	t          |	d|                      ¦   «         ƒ d {V —†i¦  «         |                      |	d|› d|› dt          |¦  «        › d�¦  «        ƒ d {V —† dS )Nr2  r¥   r¬   rÞ   z/upsertTr3  r7  s
             rP   Ú_upsertzAsyncFastAPI._upsertÖ  sº   è è € ð ØØØØð
ˆõ 	�uÐ/°t×7NÒ7NÑ7PÔ7PÐ1PÐ1PÐ1PÐ1PÐ1PÐ1PÐQÑRÔRÐRØ× Ò ØØ]˜Ð]Ð]¨8Ð]Ð]Å#ÀmÑBTÔBTÐ]Ð]Ð]ñ
ô 
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð 	
ð ˆtrQ   zAsyncFastAPI._queryÚquery_embeddingsÚ	n_resultsc
              ƒ   óÀ  K  — d„ |D ¦   «         }
|                       dd|› d|	› d|› d�||�t          |¦  «        nd ||||
dœ¬¦  «        ƒ d {V —†}|                     d	d ¦  «        }|�d
„ |D ¦   «         }t          |d         |                     dd ¦  «        |                     dd ¦  «        ||                     dd ¦  «        |                     dd ¦  «        d |¬¦  «        S )Nc                 ó   — g | ]
}|d k    ¯|‘ŒS r  rÆ   r  s     rP   r¼   z'AsyncFastAPI._query.<locals>.<listcomp>   r  rQ   r¤   r¥   r¬   rÞ   z/query)r  r;  r<  r  r  r  r§   rþ   c                 ó.   — g | ]}|�d„ |D ¦   «         nd ‘ŒS )Nc                 ó4   — g | ]}|�t          |¦  «        nd ‘ŒS rT   r  r  s     rP   r¼   z2AsyncFastAPI._query.<locals>.<listcomp>.<listcomp>  r  rQ   rÆ   r  s     rP   r¼   z'AsyncFastAPI._query.<locals>.<listcomp>  sS   € ð  ð  ð  ð ð Ð(ð	ð à$-ðñ ô ð ð
 ð ð  ð  rQ   r  Ú	distancesr  r  r   )r  rA  r  rþ   r  r   r–   r!  )rš   r4   rœ   r/   )rN   rá   r;  r  r<  r  r  r  r¢   rÈ   r"  rÃ   r  s                rP   Ú_queryzAsyncFastAPI._queryñ  sT  è è € ð ?Ð> wÐ>Ñ>Ô>Ðà×,Ò,ØØW˜ÐWÐW¨8ÐWÐWÀ-ÐWÐWÐWàà#Ð/õ %BÐBRÑ$SÔ$SÐ$SàØ&ØØ"0Ø+ð	ð 	ð -ñ 
ô 
ð 
ð 
ð 
ð 
ð 
ð 
ˆ	ð %Ÿ=š=¨°dÑ;Ô;ÐØÐ'ð ð  ð "2ð ñ  ô  Ðõ Ø˜%Ô Ø—m’m K°Ñ6Ô6Ø —}’} \°4Ñ8Ô8Ø&Ø—m’m K°Ñ6Ô6Ø—’˜v tÑ,Ô,ØØð	
ñ 	
ô 	
ð 		
rQ   zAsyncFastAPI.resetc              ƒ   óh   K  — |                       dd¦  «        ƒ d {V —†}t          t          |¦  «        S )Nr¤   z/reset)rš   r   Úbool©rN   rÃ   s     rP   ÚresetzAsyncFastAPI.reset(  s?   è è € ð ×,Ò,¨V°XÑ>Ô>Ð>Ð>Ð>Ð>Ð>Ð>ˆ	Ý•D˜)Ñ$Ô$Ð$rQ   zAsyncFastAPI.get_versionc              ƒ   óh   K  — |                       dd¦  «        ƒ d {V —†}t          t          |¦  «        S )Nrœ   z/version)rš   r   rK   rE  s     rP   Úget_versionzAsyncFastAPI.get_version.  s?   è è € ð ×,Ò,¨U°JÑ?Ô?Ð?Ð?Ð?Ð?Ð?Ð?ˆ	Ý•C˜Ñ#Ô#Ð#rQ   c                 ó   — | j         S rT   )rI   rV   s    rP   Úget_settingszAsyncFastAPI.get_settings4  s
   € àŒ~ÐrQ   z"AsyncFastAPI.get_pre_flight_checksc              ƒ   óh   K  — | j         €#|                      dd¦  «        ƒ d {V —†}|| _         | j         S )Nrœ   z/pre-flight-checks)Úpre_flight_checksrš   rE  s     rP   Úget_pre_flight_checksz"AsyncFastAPI.get_pre_flight_checks8  sJ   è è € ð Ô!Ð)Ø"×0Ò0°Ð8LÑMÔMÐMÐMÐMÐMÐMÐMˆIØ%.ˆDÔ"ØÔ%Ð%rQ   z%AsyncFastAPI.supports_base64_encodingc              ƒ   ó�   K  — |                       ¦   «         ƒ d {V —†}t          t          |                     dd¦  «        ¦  «        }|S )Nr.  F)rM  r   rD  rœ   )rN   rL  Úb64_encoding_enableds      rP   r.  z%AsyncFastAPI.supports_base64_encodingA  s[   è è € ð #'×"<Ò"<Ñ">Ô">Ð>Ð>Ð>Ð>Ð>Ð>ÐÝ#ÝÐ#×'Ò'Ð(BÀEÑJÔJñ 
ô  
Ðð $Ð#rQ   zAsyncFastAPI.get_max_batch_sizec              ƒ   ó�   K  — |                       ¦   «         ƒ d {V —†}t          t          |                     dd¦  «        ¦  «        }|S )Nr2  éÿÿÿÿ)rM  r   rŸ   rœ   )rN   rL  r2  s      rP   r4  zAsyncFastAPI.get_max_batch_sizeK  sS   è è € ð #'×"<Ò"<Ñ">Ô">Ð>Ð>Ð>Ð>Ð>Ð>ÐÝ�cÐ#4×#8Ò#8Ð9IÈ2Ñ#NÔ#NÑOÔOˆØÐrQ   )rR   r;   rh   )bÚ__name__Ú
__module__Ú__qualname__r<   r
   rŸ   ru   rv   Ú__annotations__r   rD   rW   r^   r   rd   r   ri   rU   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   r1   rD  rÜ   rà   r   rã   rå   r   rë   rí   rñ   r'   r÷   r*   ÚINDEX_AND_WALr   r!   r0   r  r	  r  r.   r  r5   r%   r,   r-   r&   r  r"   r&  ÚALLr   r$   r)   r#   r+   r0  r5  r8  r:  r6   r/   rB  rF  rH  r   rJ  rM  r.  r4  Ú__classcell__)rO   s   @rP   r;   r;   @   s!  ø€ € € € € € ð .0€Hˆd�3˜Ô)Ð)Ô*Ð/Ð/Ñ/ð
˜vð 
ð 
ð 
ð 
ð 
ð 
ð"ð ð ð ð"ð "ð "ð "ð
¨ð ¸ð Èð ÐPTð ð ð ð ð ðð ð ð ð ñ „Xðð(˜UÔ.ð (ð (ð (ð (ð> ð0 W¨S°#¨XÔ%6ð 0ð 0ð 0ñ „Xð0ð ð˜Sð ð ð ñ „Xðð+Øð+Ø!$ð+Ø04°S¸#°X´ð+à	ð+ð +ð +ð +ð$ €\Ð*Ð,DÔ,NÑOÔOØð5 ð 5ð 5ð 5ñ „Xñ PÔOð5ð €\Ð0Ð2JÔ2TÑUÔUØð %ð	
ð 	
àð	
ð ð	
ð 
ð		
ð 	
ð 	
ñ „Xñ VÔUð	
ð €\Ð-Ð/GÔ/QÑRÔRØð %ð
ð 
àð
ð ð
ð 
ð	
ð 
ð 
ñ „Xñ SÔRð
ð €\Ð0Ð2JÔ2TÑUÔUØð %ð
ð 
àð
ð ð
ð 
ð	
ð 
ð 
ñ „Xñ VÔUð
ð €\Ð/Ð1IÔ1SÑTÔTØð  $Ø $Ø$ð	
ð 
à˜Œ}ð
ð ˜”ð
ð ð	
ð
 
�(Ô	ð
ð 
ð 
ñ „Xñ UÔTð
ð, €\Ð.Ð0HÔ0RÑSÔSØð
¨ð 
°ð 
ð 
ð 
ñ „Xñ TÔSð
ð €\Ð+Ð-EÔ-OÑPÔPØð. Sð .¨Vð .ð .ð .ñ „Xñ QÔPð.ð €\Ð2Ð4LÔ4VÑWÔWØðS¨ð Sð Sð Sñ „Xñ XÔWðSð €\Ð1Ð3KÔ3UÑVÔVØð  $Ø $Ø$Ø(ðð à˜Œ}ðð ˜”ðð ð	ð
 ðð 
�/Ô	"ðð ð ñ „Xñ WÔVðð. €\Ð2Ð4LÔ4VÑWÔWØà*Ð<Lð$ð $Øð$Ø69ð$à	ð$ð $ð $ñ „Xñ XÔWð$ð €\Ð2Ð4LÔ4VÑWÔWØð $(ØAEØ15Ø#Ø$Ø(ðð àðð ˜Ô ðð  Ð =Ô>ð	ð
 Ð-Ô.ðð ðð ðð ðð 
ðð ð ñ „Xñ XÔWðð@ €\Ð/Ð1IÔ1SÑTÔTØð %Ø(ð	ð àðð ðð ð	ð
 
ðð ð ñ „Xñ UÔTðð €\Ø+Ð-EÔ-Oñô ð ð %Ø(ð	ð àðð ðð ð	ð
 
ðð ð ñ „Xñô ðð  €\Ø/Ð1IÔ1Sñô ð ð $(ØAEØ15Ø$Ø(ð
ð 
àð
ð ˜Ô ð
ð  Ð =Ô>ð	
ð
 Ð-Ô.ð
ð ð
ð ð
ð 
ð
ð 
ð 
ñ „Xñô ð
ð& €\Ð(Ð*BÔ*LÑMÔMØð #'Ø59ØEIØ$Ø(ð
ð 
àð
ð ˜3”-ð
ð Ð1Ô2ð	
ð
 $Ð$AÔBð
ð ð
ð ð
ð 
ð
ð 
ð 
ñ „Xñ NÔMð
ð. €\Ð&Ð(@Ô(JÑKÔKØð
 %Ø(ðð àðð ðð ð	ð
 ðð 
ðð ð ñ „Xñ LÔKðð €\Ð,Ð.FÔ.PÑQÔQØð %Ø(ð	
'ð 
'àð
'ð ð
'ð ð	
'ð
 
ð
'ð 
'ð 
'ñ „Xñ RÔQð
'ð €\Ø+Ð-EÔ-Oñô ð ð %Ø(ð	
ð 
àð
ð ð
ð ð	
ð
 
ð
ð 
ð 
ñ „Xñô ð
ð" €\Ð(Ð*BÔ*LÑMÔMØð
 %Ø(Ø )Ô 7ð 'ð  'àð 'ð �v”,ð 'ð ð	 'ð
 ð 'ð ð 'ð 
ð 'ð  'ð  'ñ „Xñ NÔMð 'ðD €\Ð2Ð4LÔ4VÑWÔWØð %Ø(ð		
ð 	
àð	
ð ð	
ð ð		
ð
 
ð	
ð 	
ð 	
ñ „Xñ XÔWð	
ð €\Ð'Ð)AÔ)KÑLÔLØð %Ø(Ø )Ô 7ð$ð $àð$ð ð$ð ð	$ð
 ð$ð 
ð$ð $ð $ñ „Xñ MÔLð$ð  €\Ð&Ð(@Ô(JÑKÔKØð Ø$Ø(ðð àðð ðð ð	ð
 ðð 
ðð ð ñ „Xñ LÔKðð" €\Ð%Ð'?Ô'IÑJÔJØð "Ø!%Ø#Ø $Ø26Ø3Ø$Ø(ð+
ð +
àð+
ð �cŒ]ð+
ð ˜Œð	+
ð
 ˜Œ}ð+
ð ˜”ð+
ð ! Ô/ð+
ð ð+
ð ð+
ð ð+
ð 
ð+
ð +
ð +
ñ „Xñ KÔJð+
ðZ €\Ð(Ð*BÔ*LÑMÔMØð "Ø!%Ø26Ø#Ø$Ø(ðKð KàðKð �cŒ]ðKð ˜Œð	Kð
 ! Ô/ðKð ˜Œ}ðKð ðKð ðKð 
ðKð Kð Kñ „Xñ NÔMðKð( €\Ð.Ð0HÔ0LÑMÔMð%
àØØ�ZÔ Ø�YÔØ�YÔØ�TŒNð	ô
ð%
ð ð%
ð 
ð%
ð %
ð %
ñ NÔMð%
ðN €\Ð%Ð'?Ô'CÑDÔDØð *.Ø)-Ø#Ø$Ø(ðð àðð ðð ð	ð
 ˜IÔ&ðð ˜IÔ&ðð �tŒnðð ðð ðð 
ðð ð ñ „Xñ EÔDðð2 €\Ð(Ð*BÔ*FÑGÔGØð
 ,0Ø)-Ø)-Ø#Ø$Ø(ðð àðð ðð ˜ZÔ(ð	ð
 ˜IÔ&ðð ˜IÔ&ðð �tŒnðð ðð ðð 
ðð ð ñ „Xñ HÔGðð6 €\Ð(Ð*BÔ*FÑGÔGØð *.Ø)-Ø#Ø$Ø(ðð àðð ðð ð	ð
 ˜IÔ&ðð ˜IÔ&ðð �tŒnðð ðð ðð 
ðð ð ñ „Xñ HÔGðð2 €\Ð'Ð)AÔ)EÑFÔFØð
 "ØØ!%Ø26Ø<Ø$Ø(ð3
ð 3
àð3
ð %ð3
ð �cŒ]ð	3
ð
 ð3
ð ˜Œð3
ð ! Ô/ð3
ð ð3
ð ð3
ð ð3
ð 
ð3
ð 3
ð 3
ñ „Xñ GÔFð3
ðj €\Ð&Ð(@Ô(DÑEÔEØð%˜Tð %ð %ð %ñ „Xñ FÔEð%ð €\Ð,Ð.FÔ.PÑQÔQØð$ 3ð $ð $ð $ñ „Xñ RÔQð$ð ð˜hð ð ð ñ „Xðð €\Ø,Ð.FÔ.Pñô ð&¨Sð &ð &ð &ñô ð&ð €\Ø/Ð1IÔ1Sñô ð$°ð $ð $ð $ñô ð$ð €\Ð3Ð5MÔ5WÑXÔXØð¨#ð ð ð ñ „Xñ YÔXðð ð ð ð rQ   r;   )Qro   Úuuidr   Úurllib.parser�   r‹   Útypingr   r   r   r   r   r	   r
   r   Úloggingru   Ú	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   r9   Ú	getLoggerrR  Úloggerr;   rÆ   rQ   rP   ú<module>rm     s4  ðØ €€€Ø Ð Ð Ð Ð Ð Ø Ð Ð Ð Ø €€€Ø LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LÐ LØ €€€Ø €€€Ø Ð Ð Ð Ð Ð Ø  Ð  Ð  Ð  Ð  Ð  Ø &Ð &Ð &Ð &Ð &Ð &Ø 1Ð 1Ð 1Ð 1Ð 1Ð 1Ø 8Ð 8Ð 8Ð 8Ð 8Ð 8ðð ð ð ð ð ð ð ð ð ð ð ð OÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ NÐ Nðð ð ð ð ð ð ð ð ð ð
 >Ð =Ð =Ð =Ð =Ð =Ø 6Ð 6Ð 6Ð 6Ð 6Ð 6Ø JÐ JÐ JÐ JÐ JÐ JÐ JÐ JÐ JÐ JØ 5Ð 5Ð 5Ð 5Ð 5Ð 5ðð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð ð0ð ð ð ð ð ð ð ð ð ð 
ˆÔ	˜8Ñ	$Ô	$€ðPð Pð Pð Pð P�> >ñ Pô Pð Pð Pð PrQ   