LKi$rSSKrSSKJrJrJrJr SSKJrJr SSK J r J r SSK J s Jr SSKJr SSKJr SSKJrJrJr SSKrSSKJr SSKrSS KJrJrJrJrJ r SS K!J"r" SS K#J$r$ SSK%r%SS K&J'r' SS K(J)r) SSK*J+r+ SSK,J-r- \R\"\/5r0"SS\Rb5r1"SS\\\5r2g)N) ConnectionLockPool PerThreadPoolPool) MigratableDB Migration)SystemSettings)SqlEmbeddingsQueue)SqlSysDB)OpenTelemetryClientOpenTelemetryGranularity trace_method)override)SequencecastOptionalTypeAny)Literal) TracebackTypeUUID)local)files) Traversablec \rSrSr%\\S'\\S'S\S\4Sjr\ S\ R4Sj5r \ S \ \\S \ \S \ \S\S 4S j5rSrg) TxWrapper_conn_pool conn_poolstackcFX lUR5UlXlgN) _tx_stackconnectr r!)selfr"r#s Y/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/db/impl/sqlite.py__init__TxWrapper.__init__ s&&(  returnc2[URR5S:Xa6URR S5 URR S5 URRR U5 URR 5$)NrPRAGMA case_sensitive_like = ONzBEGIN;)lenr&r#r executeappendcursorr(s r) __enter__TxWrapper.__enter__%si t~~## $ ) JJ  @ A JJ  x ( ##D)zz  ""r,exc_type exc_value tracebackFcURRR5 [URR5S:Xa8UcURR 5 OURR 5 URR5R5 URRUR5 g)NrF) r&r#popr0r commitrollbackr3closer!return_to_pool)r(r7r8r9s r)__exit__TxWrapper.__exit__-s   " t~~## $ ) !!# ##% !!# !!$**-r,)r r!r&N)__name__ __module__ __qualname____firstlineno__r__annotations__rrr*rbaseCursorr5rr BaseExceptionrrr@__static_attributes__r,r)rrs  K$u #4;;##4 ./M*M*   r,rc^\rSrSr%\\S'\\S'\\\S'\ \S'\ \S'\ \S'S\ 4U4S jjr \"S \R 5\S)U4S jj55r\"S\R 5\S)U4Sjj55r\\S \\R.4Sj55r\\S \ 4Sj55r\\S \ 4Sj55r\S \\4Sj5r\S \4Sj5r\"S\R 5\S)U4Sjj55r\"S\R 5\S)Sj55r\"S\R 5\S \ 4Sj55r \"S\R 5\S\S \\!4Sj55r"\S\#RHS\!S S 4S j5r%\\S!\&\'S \&\(4S"j55r)\\S#\&\(S \&\'4S$j55r*\\S \\+4S%j55r,S*S&\-S S 4S'jjr.S(r/U=r0$)+SqliteDB? _conn_pool _settings_migration_imports_db_filer&_is_persistentsystemc>URUl[S5[S5[S5/UlURR S5UlUR [ 5UlUR (d!SUl[URSS9Ul OURR S5S -Ul[RRUR5(d<[R"[RRUR5SS 9 [!UR5Ul [#5Ul[&TU]QU5 g) Nz$chromadb.migrations.embeddings_queuezchromadb.migrations.sysdbzchromadb.migrations.metadb is_persistentzfile::memory:?cache=sharedT)is_uripersist_directoryz/chroma.sqlite3)exist_ok)settingsrPrrQrequirerSr _opentelemetry_clientrRrrOospathexistsmakedirsdirnamerrr&superr*)r(rT __class__s r)r*SqliteDB.__init__Gs 8 9 - . . /#  #nn44_E%+^^4G%H""" 9DM&t}}TBDO&&':;>OO M77>>$--00 BGGOODMM:TJ+DMM:DO  r,zSqliteDB.startr-Nc>[TU]5 UR5nURS5 URS5 SSS5 UR 5 UR R S5S:Xa?URRS5RSLa[RS5 ggg!,(df  N}=f)NzPRAGMA foreign_keys = ONr/ migrationsapplyautomatically_purgeFu⚠️ It looks like you upgraded from a version below 0.5.6 and could benefit from vacuuming your database. Run chromadb utils vacuum --help for more information.) rbstarttxr1initialize_migrationsrPr[config get_parametervalueloggerwarning)r(currcs r)riSqliteDB.startas   WWY# KK2 3 KK9 : ""$ NN " "< 0G ; ))*?@FF%O NNv P <Ys #B:: Cz SqliteDB.stopcV>[TU]5 URR5 gr%)rbstoprOr>)r(rcs r)rt SqliteDB.stopss   r,c"[R$r%)pypikaQueryrKr,r) querybuilderSqliteDB.querybuilderys||r,cg)N?rKrKr,r)parameter_formatSqliteDB.parameter_format~sr,cg)NsqliterKrKr,r)migration_scopeSqliteDB.migration_scopesr,cUR$r%)rQr4s r)migration_dirsSqliteDB.migration_dirss&&&r,c[URS5(d/URl[URURS9$)Nr#)r#)hasattrr&r#rrOr4s r)rj SqliteDB.txs4t~~w//#%DNN ??r,zSqliteDB.reset_statec>URRS5(d [S5eUR5nUR S5 UR 5HnUR SUS35 M SSS5 UR R5 UR5 [TU])5 g!,(df  NG=f)N allow_resetzResetting the database is not allowed. Set `allow_reset` to true in the config in tests or other non-production environments where reset should be permitted.zo SELECT name FROM sqlite_master WHERE type='table' zDROP TABLE IF EXISTS r) rPr[ ValueErrorrjr1fetchallrOr>rirb reset_state)r(rqrowrcs r)rSqliteDB.reset_states~~%%m44p WWY# KK  ||~ 3CF8<=&   Ys AB>> C zSqliteDB.setup_migrationsczUR5nURS5 SSS5 g!,(df  g=f)Na~ CREATE TABLE IF NOT EXISTS migrations ( dir TEXT NOT NULL, version INTEGER NOT NULL, filename TEXT NOT NULL, sql TEXT NOT NULL, hash TEXT NOT NULL, PRIMARY KEY (dir, version) ) )rjr1r(rqs r)setup_migrationsSqliteDB.setup_migrationss*WWY# KK  YYs, :zSqliteDB.migrations_initializedcUR5nURS5 UR5SS:Xa SSS5 gSSS5 g!,(df  g=f)Nz[SELECT count(*) FROM sqlite_master WHERE type='table' AND name='migrations'rFT)rjr1fetchoners r)migrations_initializedSqliteDB.migrations_initializedsNWWY# KK<  ||~a A%YYYs*AA AzSqliteDB.db_migrationsdirc UR5nURSUR45 /nUR5Hn[ [ US5n[ [ US5n[ [ US5n[ [ US5n[ [ US5n UR[UUUUU UR5S95 M UsSSS5 $!,(df  g=f)Nz SELECT dir, version, filename, sql, hash FROM migrations WHERE dir = ? ORDER BY version ASC r)rversionfilenamesqlhashscope) rjr1namerrstrintr2rr) r(rrqrfr found_dir found_versionfound_filename found_sql found_hashs r) db_migrationsSqliteDB.db_migrationssWWY# KK   J||~ c!f- $S#a& 1 !%c3q6!2 c!f- !#s1v. !!% -!/%'"224   & 9YYs CC C+rq migrationc xURUS5 URSUSUSUSUSUS45 g)Nrzw INSERT INTO migrations (dir, version, filename, sql, hash) VALUES (?, ?, ?, ?, ?) rrrr) executescriptr1)r(rqrs r)apply_migrationSqliteDB.apply_migrationsU )E*+   % )$*%% &!   r,rnc"Ub [U5$S$r%r)rns r) uuid_from_dbSqliteDB.uuid_from_dbs$/tE{9T9r,uuidc"Ub [U5$S$r%)r)rs r) uuid_to_dbSqliteDB.uuid_to_dbs!,s4y6$6r,c"[R$r%)sqlite3IntegrityErrorrKr,r)unique_constraint_error SqliteDB.unique_constraint_errors%%%r,timeoutcURR5nURS[U5S-35 URS5 URS5 g)zdRuns VACUUM on the database. `timeout` is the maximum time to wait for an exclusive lock in seconds.zPRAGMA busy_timeout = iVACUUMz} INSERT INTO maintenance_log (operation, timestamp) VALUES ('vacuum', CURRENT_TIMESTAMP) N)rOr'r1r)r(rconns r)vacuumSqliteDB.vacuumsO&&( -c'lT.A-BCD X   r,)rOrRrSrQr\rPr&)r-N))1rBrCrDrErrFr rrrrboolr r*rrALLrrirt staticmethodrrwrxryr}rrrrjrrrrrrGrHrrrrrrrIrrrrJ __classcell__)rcs@r)rMrM?s --M!v!4"$<$@$@A B /#;#?#?@  A  $v||, c S' 5''@I@@ (*B*F*FG H&-/G/K/KL  M 35M5Q5QR   S *,D,H,HI )1DJ> 4;; 9    :HSM:htn:: 7$7HSM77 &T-%8&&  c  $   r,rM)3loggingchromadb.db.impl.sqlite_poolrrrrchromadb.db.migrationsrrchromadb.configr r chromadb.db.basedbrG#chromadb.db.mixins.embeddings_queuer chromadb.db.mixins.sysdbr chromadb.telemetry.opentelemetryr rrr overridesrrwtypingrrrrrtyping_extensionsrtypesrr]rr threadingrimportlib_resourcesrimportlib_resources.abcr getLoggerrBrorrMrKr,r)rsRR:,B-  66% %/   8 $  FR |/R r,