OiUddlmZddlmZmZmZmZmZmZm Z m Z m Z ddl m Z ddlmZddlZddlZddlmZmZddlmZddlZdZ dd lmZn #e$rdZYnwxYwejeZd d d d ddZddddddddZee e fe!d<GddeZ"eddZ#GddeeZ$Gdd e$Z%ed!Z&d"e d#e e&d$e e&fd%Z'd&e e(d$e fd'Z)dS)() BaseSettings) OptionalListAnyDictTypeVarSetcastIterableType)Literal)ABCN)EnforceOverridesoverride)TopologicalSorterF)is_thin_clientchromadb.db.duckdb.DuckDBz#chromadb.db.duckdb.PersistentDuckDBz!chromadb.db.clickhouse.Clickhousezchromadb.api.fastapi.FastAPIchromadb.api.local.LocalAPI)duckdbzduckdb+parquet clickhouserestlocalchroma_db_implchroma_api_implchroma_telemetry_implchroma_producer_implchroma_consumer_implchroma_sysdb_implchroma_segment_manager_impl)zchromadb.db.DBzchromadb.api.APIzchromadb.telemetry.Telemetryzchromadb.ingest.Producerzchromadb.ingest.Consumerzchromadb.db.system.SysDBzchromadb.segment.SegmentManager_abstract_type_keysceZdZUdZeed<dZeed<dZeed<dZeed<d Z eed <d Z eed <d Z eed <d Z eed<dZ eeed<dZeeed<dZeed<dZeed<dZeed<dZeeed<dZeeed<dZeeed<dZeeed<gZeeed<dZeed<dZeed<d Zeeed!<d"Zed#ed$<d%ed&efd'Z d%ed&efd(Z!Gd)d*Z"dS)+Settings environmentrrrrz"chromadb.telemetry.posthog.Posthogrz chromadb.db.impl.sqlite.SqliteDBrrrz7chromadb.segment.impl.manager.local.LocalSegmentManagerrNclickhouse_hostclickhouse_portdefault tenant_idtopic_namespacez.chromapersist_directorychroma_server_hostchroma_server_http_portFchroma_server_ssl_enabledchroma_server_grpc_port chroma_server_cors_allow_originsTanonymized_telemetry allow_resetz:memory:sqlite_databaseapply)nonevalidater3 migrationskeyreturnc@||}|td|d|S)zYReturn the value of a required config key, or raise an exception if it is not setNzMissing required config value '') ValueError)selfr7vals j/var/www/html/web/mlink/mlink_AI_Server/mlink-backend/venv/lib/python3.11/site-packages/chromadb/config.pyrequirezSettings.requireMs13i ;EsEEEFF F cVt||}|tvrt|}|}|SN)getattr_legacy_config_values)r<r7r=newvals r> __getitem__zSettings.__getitem__Us1dC   ' ' '*3/FC r@ceZdZdZdZdS)Settings.Configz.envzutf-8N)__name__ __module__ __qualname__env_fileenv_file_encodingr@r>ConfigrH]s#r@rO)#rIrJrKr$str__annotations__rrrrrrrr%rr&r(r)r*r+r,r-boolr.r/rr0r1r2r6r rr?rFrOrNr@r>r"r")s!K5NC5558OS888!E3EEE@s??? B#BBB B#BBBA &*OXc])))%)OXc])))Is$OS$$$&s&&&(, ,,,-1Xc]11105x~555-1Xc]11124$d3i444!%$%%%K%/OXc]///7>J34>>>33ss$$$$$$$$$$r@r"T Component)boundceZdZUeded<ded<eed<ddZdeedefd Z dedfd Z dd Z dd Z ddZ d S)rT _dependenciesSystem_system_runningsystemcHt|_||_d|_dS)NF)setrWrYrZ)r<r[s r>__init__zComponent.__init__js  UU  r@typer8cn|j|}|j||S)zbGet a Component instance of the given type, and register as a dependency of that instance.)rYinstancerWadd)r<r_insts r>r?zComponent.requireos5|$$T** t$$$ r@c|jS)z dependencieszComponent.dependenciesvs !!r@Ncbtd|jjd|_dS)zWIdempotently stop this component's execution and free all associated resources.zStopping component FNloggerdebug __class__rIrZres r>stopzComponent.stopzs/  D4>+BDDEEE r@cbtd|jjd|_dS)z-Idempotently start this component's executionzStarting component TNrhres r>startzComponent.starts- D4>+BDDEEE r@cTtd|jjdS)zgReset this component's state to its initial blank state. Only intended to be called from tests.zResetting component N)rirjrkrIres r> reset_statezComponent.reset_states*  EDN,CEEFFFFFr@)r[rXr8N)rIrJrKr rQrRr^r rSr?rfrlrnrprNr@r>rTrTes{#### NNN DG"c+.""""  GGGGGGr@ceZdZUeed<eeeefed<deffd Zdee de fdZ de efdZ e d fd Ze d fd Ze d d ZxZS) rXsettings _instancescf||_i|_t|dSrB)rsrtsuperr^)r<rsrks r>r^zSystem.__init__s/   r@r_r8ctj|rat|}|tvrt d|t|}|j|}t||}||jvr0||}||j|<|j r| |j|}tt|S)z|Return an instance of the component type specified. If the system is running, the component will be started as well.z"Cannot instantiate abstract type: ) inspect isabstractget_fqnr r;rsr? get_classrtrZrnr rS)r<r_type_fqnr7fqnimplrcs r>razSystem.instances  d # # (t}}H222 !Ld!L!LMMM%h/C-'',,CS$''D t & &4::D$(DOD !}  t$At}}r@ct}|jD]"}|j|g|R#|S)zYReturn the full set of all components and their dependencies in dependency order.)rrtvaluesrbrf static_order)r<sorter components r> componentszSystem.componentssh0A/B/B//11 = =I FJy <9#9#9#;#; < < < < <""$$$r@Nct|D]}|dSrB)rvrnrr<rrks r>rnz System.startsJ  **  I OO      r@cttt|D]}|dSrB)rvrlreversedlistrrs r>rlz System.stopsZ  !$t'8'8"9"9::  I NN      r@c|jjstdtt |D]}|dS)zOReset the state of this system and all constituents in reverse dependency orderz.Resetting is not allowed by this configurationN)rsr1r;rrrrp)r<rs r>rpzSystem.reset_statesi}( OMNN N!$t'8'8"9"9:: $ $I  ! ! # # # # $ $r@rq)rIrJrKr"rQrr rTr^rSrar rrrnrlrp __classcell__)rks@r>rXrXs&T)_i/0000 T!W*%HY/%%%%X X $$$X$$$$$r@rXCr}r_r8c|dd\}}tj|}t||}t t t |S)zIGiven a fully qualifed class name, import the module and return the class.)rsplit importlib import_modulerCr r r)r}r_ module_name class_namemoduleclss r>r{r{sM!jja00K  $[ 1 1F &* % %C Q  r@rc$|jd|jS)z.Given a class, return its fully qualified namer)rJrI)rs r>rzrzsn - -s| - --r@)*pydanticrtypingrrrrrr r r r typing_extensionsr abcrrlogging overridesrrgraphlibrrxrchromadb.is_thin_client ImportError getLoggerrIrirDr rPrQr"rSrTrXrr{objectrzrNr@r>rs!!!!!!!PPPPPPPPPPPPPPPPPPPPPP%%%%%%00000000&&&&&&6666666NNN  8 $ $*;5 * * ')$; 6 6 3'D''T#s(^6$6$6$6$6$|6$6$6$r GC{####G#G#G#G#G%#G#G#GL:$:$:$:$:$Y:$:$:$z GCLL3d1g$q'.f.#......sAAA