LKiNTSSKJrJr SSKJr SSKJr SSKrSSKJ r J r J r SSK J r JrJrJr SSKJr SSKJrJrJrJrJrJrJrJrJrJrJrJrJ r J!r!J"r"J#r#J$r$ SS K%J&r& SS K'J(r( SS K)J*r*J+r+ SS K)J,r,J-r- SS K.J/r/ SSK0J1r1J2r2 SSK3J4r4J5r5J6r6J7r7 "SS\\ 5r8"SS\\ 5r9g))OptionalSequence)UUID)overrideN)AdminAPI ClientAPI ServerAPI)CreateCollectionConfigurationUpdateCollectionConfiguration.validate_embedding_function_conflict_on_create+validate_embedding_function_conflict_on_get)SharedSystemClient)CollectionMetadata DataLoader Documents EmbeddableEmbeddingFunction Embeddings GetResultIDsIncludeLoadable Metadatas QueryResultSchemaURIsIncludeMetadataDocuments!IncludeMetadataDocumentsDistancesDefaultEmbeddingFunction) UserIdentity)maybe_set_tenant_and_database)SettingsSystem)DEFAULT_TENANTDEFAULT_DATABASE) Collection)ChromaAuthError ChromaError)DatabaseTenantWhere WhereDocumentc^\rSrSr%Sr\r\\S'\ r \\S'\ \S'\ \S'\\ \ "54S\\S\\S\ SS 4U4S jjjr\\\\ 4S \S\S\SS4S jj55r\S\4S j5r\S\4Sj5r\SAS\\S\\S\\4Sjj5r\S\4Sj5r\S S S \"5S S4S\S\\S\\S\\S\\ \!S\\"\#S\$S\4Sjj5r%\\"5S 4S\S\\ \!S\\"\#S\4Sjj5r&\S S S \"5S 4S\S\\S\\S\\S\\ \!S\\"\#S\4Sjj5r'\SBS\(S\\S \\S!\\)SS 4 S"jj5r*\S\SS 4S#j5r+\SBS$\,S%\(S&\-S'\\.S(\\/S)\\0S\$4S*jj5r1\SCS%\(S$\,S&\\-S'\\.S(\\/S)\\0S\$4S+jj5r2\SBS%\(S$\,S&\-S'\\.S(\\/S)\\0S\$4S,jj5r3\S%\(S\4S-j5r4\SDS%\(S/\S\54S0jj5r6\S S S S S \74S%\(S$\\,S1\\8S\\S\\S2\\9S3\:S\54S4jj5r;SAS%\(S$\\,S1\\8S2\\9SS 4 S5jjr<\S S.S S \=4S%\(S6\-S$\\,S7\S1\\8S2\\9S3\:S\>4S8jj5r?\S\$4S9j5r@\S\4S:j5rA\S\ 4S;j5rB\S\4S<j5rC\\ 4S\S\SS 4S=jj5rD\S\SS 4S>j5rES\S\SS 4S?jrFS@rGU=rH$)EClient*aA client for Chroma. This is the main entrypoint for interacting with Chroma. A client internally stores its tenant and database and proxies calls to a Server API instance of Chroma. It treats the Server API and corresponding System as a singleton, so multiple clients connecting to the same resource will share the same API instance. Client implementations should be implement their own API-caching strategies. tenantdatabase_server _admin_clientsettingsreturnNc>[TU]US9 UbXlUbX lURR [ 5UlUR5n[UURUUS9upVUcUc [S5eUcUc [S5eU(aXPlU(aX`l[RUR5UlURURURS9 UR!5 g)Nr4)4overwrite_singleton_tenant_database_access_from_authuser_provided_tenantuser_provided_databasez]Could not determine a tenant from the current authentication method. Please provide a tenant.zkCould not determine a database name from the current authentication method. Please provide a database name.r0r1)super__init__r0r1_systeminstancer r2get_user_identityr!;chroma_overwrite_singleton_tenant_database_access_from_authr' AdminClient from_systemr3_validate_tenant_database_submit_client_start_event)selfr0r1r4 user_identity maybe_tenantmaybe_database __class__s U/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/api/client.pyr=Client.__init__<s (+   K  $M||,,Y7 ..0 'D AIBFBF!'#+ ( $   FN!o   !h&6!}  &K *M)44T\\B &&dkkDMM&R '')systemcT[R"U5 U"X#URS9nU$)N)r0r1r4r_populate_data_from_systemr4)clsrNr0r1r?s rKrCClient.from_systemis' 55f=f&//RrMcURR5$![Ra [ S5e[ anUeSnAf[ an[ [U55eSnAff=f)NACould not connect to a Chroma server. Are you sure it is running?)r2r@httpx ConnectError ValueErrorr( Exceptionstr)rFes rKr@Client.get_user_identitywsg %<<113 3!! S  G %SV$ $ %s!(A,A A,A''A,c6URR5$)z2Return the server time in nanoseconds since epoch.)r2 heartbeatrFs rKr^Client.heartbeats||%%''rMlimitoffsetcURRXURURS9Vs/sHn[ URUS9PM sn$s snf)zList collections for the current tenant and database, with pagination. Returns: Sequence[Collection]: Collection objects for the current tenant. r;)clientmodel)r2list_collectionsr0r1r&)rFrarbres rKrfClient.list_collectionss[66dkkDMM7  dll% 8   sAc^URRURURS9$)z9Return the number of collections in the current database.r;)r2count_collectionsr0r1r_s rKriClient.count_collectionss-||--;;.  rMFnameschema configurationmetadataembedding_function data_loader get_or_createc Uc0nURS5n[XX5 UbUcXSS'URRUUUURUR UUS9n [ URU UUS9$)aCreate a collection with optional configuration and metadata. If using a schema, do not provide `embedding_function`. Instead, provide the `embedding_function` as part of the schema. Args: name: Collection name. schema: Optional collection schema for indexes and encryption. configuration: Optional collection configuration. metadata: Optional collection metadata. embedding_function: Optional embedding function for the collection. data_loader: Optional data loader for documents with URIs. get_or_create: Whether to return an existing collection if present. Returns: Collection: The created collection. Raises: ValueError: If the embedding function conflicts with configuration. ro)rkrlrnr0r1rqrmrdrerorp)getr r2create_collectionr0r1r&) rFrkrlrmrnrorprqconfiguration_efres rKruClient.create_collectionsB  M(,,-AB6   ).>.F2D. / ..;;]]''/ <<1#   rMcURRUURURS9nURR S5n[ X%5 [URUUUS9$)aHGet a collection by name. Args: name: Collection name. embedding_function: Optional embedding function for the collection. data_loader: Optional data loader for documents with URIs. Returns: Collection: The requested collection. Raises: ValueError: If the embedding function conflicts with configuration. rkr0r1rors)r2get_collectionr0r1configuration_jsonrtr r&)rFrkrorprepersisted_ef_configs rKrzClient.get_collectionsr, ++;;]],  $66::;OP3  <<1#   rMc 4Uc0nURS5n[XW5 UbUcXSS'URRUUUURUR US9nUR RS5n [XY5 [URUUUS9$)aGet an existing collection or create a new one. If the collection does not exist, it will be created. If the collection already exists, the schema, configuration, and metadata arguments will be ignored. Args: name: Collection name. schema: Optional collection schema for indexes and encryption. configuration: Optional collection configuration. metadata: Optional collection metadata. embedding_function: Optional embedding function for the collection. data_loader: Optional data loader for URI-backed data. Returns: Collection: The existing or newly created collection. Raises: ValueError: If the embedding function does not match the collection's embedding function. ro)rkrlrnr0r1rmrs) rtr r2get_or_create_collectionr0r1r{r r&) rFrkrlrmrnrorprvrer|s rKrClient.get_or_create_collection s@  M(,,-AB6    ).>.F2D. / 55;;]]' 6 $66::;OP3  <<1#   rMidnew_name new_metadatanew_configurationc fURRUURURUUUS9$)N)rr0r1rrr)r2_modifyr0r1)rFrrrrs rKrClient._modifyKs:||##;;]]%/ $  rMc`URRUURURS9$)Nry)r2delete_collectionr0r1rFrks rKrClient.delete_collection\s1 ||--;;]].  rMids collection_id embeddings metadatas documentsurisc jURRUURURUUUUUS9$)N)rr0r1rrrrr)r2_addr0r1)rFrrrrrrs rKr Client._addks@||  ;;]]'!!  rMc jURRUURURUUUUUS9$N)rr0r1rrrrr)r2_updater0r1rFrrrrrrs rKrClient._update@||##';;]]!$  rMc jURRUURURUUUUUS9$r)r2_upsertr0r1rs rKrClient._upsertrrMc`URRUURURS9$)N)rr0r1)r2_countr0r1)rFrs rKr Client._counts/||""';;]]#  rM ncbURRUUURURS9$)N)rrr0r1)r2_peekr0r1)rFrrs rKr Client._peeks2||!!';;]] "  rMwherewhere_documentincludec lURRUURURUUUUUUS9 $)N) rr0r1rrrarbrr)r2_getr0r1)rFrrrrarbrrs rKr Client._getsC||  ';;]])!  rMc hURRUURURUUUS9 g)N)rr0r1rrr)r2_deleter0r1)rFrrrrs rKrClient._deletes5 ';;]])  rMquery_embeddings n_resultsc lURRUUURURUUUUUS9 $)N) rrr0r1rrrrr)r2_queryr0r1)rFrrrrrrrs rKr Client._querysC||""';;]]-)#  rMc6URR5$N)r2resetr_s rKr Client.resets||!!##rMc6URR5$r)r2 get_versionr_s rKrClient.get_versions||''))rMc6URR5$r)r2 get_settingsr_s rKrClient.get_settingss||((**rMc6URR5$r)r2get_max_batch_sizer_s rKrClient.get_max_batch_sizes||..00rMc:URXS9 XlX lgNr;rDr0r1)rFr0r1s rK set_tenantClient.set_tenant s &&f&H  rMcDURURUS9 Xlgrr)rFr1s rK set_databaseClient.set_databases &&dkkH&M rMcFURRUS9 URRX!S9 g![Ra [ S5e[ anUeSnAf[ a [ SUS35ef=f![Ra [ S5ef=f)NrkrUzCould not connect to tenant z. Are you sure it exists?rkr0)r3 get_tenantrVrWrXr(rY get_database)rFr0r1r[s rKrD Client._validate_tenant_databases     ) )v ) 6     + + + I!! S  G .vh6OP  !! S  s 6B(A=A  A= B )r3r2r1r0)NN)NNN)NNNN)r)I__name__ __module__ __qualname____firstlineno____doc__r$r0rZ__annotations__r%r1r rr"rr= classmethodrr#rCr r@intr^rr&rfrirrr rrrrrboolrurzrrr rrrrrrrrrrrrrrr+r,rrrrrrrrrrrrrD__static_attributes__ __classcell__rJs@rKr.r.*s8!FC $Hc$  !/"2%Z +* +*3-+* +*  +*+*Z %(     %< % %(3((CG  c]  3;C=  *      3  $(AE15 % &6:#< <  <  => < -. < % j ) < j23< <  < < | % &6: % % % j ) % j23 %  % % N$(AE15 % &6:> >  >  => > -. > % j ) > j23>  > > @#'59EI   3- 12  $$AB           *.)-#     I&  I&  tn    ( ,0)-)-#   Z(  I&  I&  tn    ( *.)-#     I&  I&  tn    ( D S   4 C   "!%# $263  c]   }    !/     4"&26   c]   !/     "!%26<  % c]      !/     ,$t$$*S**+h++1C116F!!!4!! !S!T!!strMr.c d^\rSrSr%Sr\\S'\"54S\SS4U4Sjjjr\ \ 4S\ S \ SS4S jj5r \ \ 4S\ S \ S\ 4S jj5r\ \ 4S\ S \ SS4S jj5r\ SS\ 4S \\S\\S \ S\\ 4Sjj5r\ S\ SS4Sj5r\ S\ S\4Sj5r\\ S\SS4Sj55rSrU=r$)rBi1z0Admin client for managing tenants and databases.r2r4r5Ncl>[TU]U5 URR[5Ulgr)r<r=r>r?r r2)rFr4rJs rKr=AdminClient.__init__6s& "||,,Y7 rMrkr0c4URRXS9$)zjCreate a database in a tenant. Args: name: Database name. tenant: Tenant that owns the database. r)r2create_databaserFrkr0s rKrAdminClient.create_database:||+++EErMc4URRXS9$)zGet a database by name. Args: name: Database name. tenant: Tenant that owns the database. Returns: Database: The database record. r)r2rrs rKrAdminClient.get_databaseDs||((d(BBrMc4URRXS9$)zfDelete a database by name. Args: name: Database name. tenant: Tenant that owns the database. r)r2delete_databasers rKrAdminClient.delete_databaseQrrMrarbc6URRXUS9$)N)r0)r2list_databases)rFrarbr0s rKrAdminClient.list_databases[s||**5*HHrMc4URRUS9$Nr)r2 create_tenantrs rKrAdminClient.create_tenantds||))t)44rMc4URRUS9$r)r2rrs rKrAdminClient.get_tenanths||&&D&11rMrNcR[R"U5 U"URS9nU$)Nr7rP)rRrNr?s rKrCAdminClient.from_systemls% 55f=0rM)r2)rrrrrr rr"r=rr$rZrr)rrrrrrrr*rrr#rCrrrs@rKrBrB1s: ,4J884887EFCFF$FF4B C Cc Cx C C7EFCFF$FF $ $$ I}I I I (  II5#5$552s2v22  rMrB):typingrruuidr overridesrrV chromadb.apirrr %chromadb.api.collection_configurationr r r r !chromadb.api.shared_system_clientrchromadb.api.typesrrrrrrrrrrrrrrrrr chromadb.authr chromadb.auth.utilsr!chromadb.configr"r#r$r%chromadb.api.models.Collectionr&chromadb.errorsr'r(chromadb.typesr)r*r+r,r.rBrMrKrs}% 77 A&'=,<58AAB BNC$hCrM