LKi% SSKrSSKJr SSKJrJr SSKJr SSKrSSK r SSK J r J r SSK Jr SSKJrJr SSKJrJrJr "S S \5r"S S \5r"S S\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\5r"SS\ 5r\R@"S5r!S\"S\"S\S\4S jr#S!\\S"\\S\\4S#jr$S)S\S$\"S%\"S\\4S&jjr%S'\S%\"S\4S(jr&g)*N)Sequence) TypedDict NotRequired) Traversable)SqlDBCursor)abstractmethod)SystemSettings)OpenTelemetryClientOpenTelemetryGranularity trace_methodcN\rSrSr%\\\S'\\S'\\S'\\S'\\S'Sr g) MigrationFilepathdirfilenameversionscopeN) __name__ __module__ __qualname____firstlineno__rr__annotations__strint__static_attributes__rX/var/www/html/dynamic-report/venv/lib/python3.13/site-packages/chromadb/db/migrations.pyrrs! k "" HM L Jr rc*\rSrSr%\\S'\\S'Srg) MigrationhashsqlrN)rrrrrrrrr r!r#r#s I Hr r#c,^\rSrSrSU4SjjrSrU=r$)UninitializedMigrationsErrorc$>[TU]S5 g)Nz$Migrations have not been initializedsuper__init__)self __class__s r!r-%UninitializedMigrationsError.__init__s ?@r rreturnN)rrrrr-r __classcell__r/s@r!r(r(sAAr r(c4^\rSrSrS\S\4U4SjjrSrU=r$)UnappliedMigrationsError#rrcH>XlX l[TU] SUSU35 g)NzUnapplied migrations in z, starting with version )rrr,r-)r.rrr/s r!r-!UnappliedMigrationsError.__init__$s+  &se+CG9 M r rr rrrrrrr-rr3r4s@r!r6r6#s C #  r r6c8^\rSrSrS\S\S\4U4SjjrSrU=r$)InconsistentVersionError,r db_versionsource_versioncF>[TU]SUS3SUSUS3-S-5 g)Nz#Inconsistent migration versions in :zdb version was z, source version was .zH Has the migration sequence been modified since being applied to the DB?r+)r.rr?r@r/s r!r-!InconsistentVersionError.__init__-s@ 1#a 8 |+@@PPQR SX Y r rr;r4s@r!r=r=,s" C S #  r r=c8^\rSrSrS\S\S\4U4SjjrSrU=r$)InconsistentHashError5rdb_hash source_hashcF>[TU]SUS3SUSUS3-S-5 g)NzInconsistent hashes in rBz db hash was z, source has was rCz? Was the migration file modified after being applied to the DB?r+)r.rrHrIr/s r!r-InconsistentHashError.__init__6s> %dV1 -WI%6{m1E FO P r rrrrrrr-rr3r4s@r!rFrF5s" S 3 S  r rFc0^\rSrSrS\4U4SjjrSrU=r$)InvalidHashError>algc*>[TU]SU35 g)Nz"Invalid hash algorithm specified: r+)r.rPr/s r!r-InvalidHashError.__init__?s =cUCDr rrLr4s@r!rNrN>sECEEr rNc\rSrSrSrg)InvalidMigrationFilenameCrN)rrrrrrr r!rTrTCsr rTch^\rSrSr%Sr\\S'S\SS4U4Sjjr\ \ S\ 4Sj55r \ S\ \4S j5r\ SS j5r\ S\4S j5r\ S \S\ \4S j5r\ S\S\SS4Sj5rSSjr\"S\R45SSj5r\"S\R45SSj5rSrU=r$) MigratableDBGa}Simple base class for databases which support basic migrations. Migrations are SQL files stored as package resources and accessed via importlib_resources. All migrations in the same directory are assumed to be dependent on previous migrations in the same directory, where "previous" is defined on lexographical ordering of filenames. Migrations have a ascending numeric version number and a hash of the file contents. When migrations are applied, the hashes of previous migrations are checked to ensure that the database is consistent with the source repository. If they are not, an error is thrown and no migrations will be applied. Migration files must follow the naming convention: ...sql, where is a 5-digit zero-padded integer, is a short textual description, and is a short string identifying the database implementation. _settingssystemr2Ncz>URUlUR[5Ul[ TU]U5 g)N)settingsrYrequirer _opentelemetry_clientr,r-)r.rZr/s r!r-MigratableDB.__init__^s-%+^^4G%H"  r cg)zFThe database implementation to use for migrations (e.g, sqlite, pgsql)Nrrr r!migration_scopeMigratableDB.migration_scopec r cg)zQDirectories containing the migration sequences that should be applied to this DB.Nrr.s r!migration_dirsMigratableDB.migration_dirsircr cg)z)Idempotently creates the migrations tableNrres r!setup_migrationsMigratableDB.setup_migrationso r cg)z*Return true if the migrations table existsNrres r!migrations_initialized#MigratableDB.migrations_initializedtrkr rcg)zvReturn a list of all migrations already applied to this database, from the given source directory, in ascending order.Nr)r.rs r! db_migrationsMigratableDB.db_migrationsyrcr cur migrationcg)z(Apply a single migration to the databaseNr)r.rrrss r!apply_migrationMigratableDB.apply_migrationrkr cURRS5nUS:XaUR5 US:XaUR5 gg)z!Initialize migrations for this DB migrationsvalidateapplyN)rYr]validate_migrationsapply_migrations)r.migrates r!initialize_migrations"MigratableDB.initialize_migrationssC..((6 j  $ $ & g   ! ! # r z MigratableDB.validate_migrationscfUR5(d [5eUR5H~nURU5n[ UUR 5UR RS55n[X#5n[U5S:dMdUSSn[URUS9e g)zhValidate all migrations and throw an exception if there are any unapplied migrations in the source repo.migrations_hash_algorithmrrr:N) rmr(rfrpfind_migrationsrarYr]verify_migration_sequencelenr6name)r.rrpsource_migrationsunapplied_migrationsrs r!r{ MigratableDB.validate_migrationss**,,.0 0&&(C ..s3M /$$&&&'BC!  $=$ '(1,.q1)<.388WMM)r zMigratableDB.apply_migrationsc|UR5 UR5HnURU5n[UUR 5UR R S55n[X#5nUR5nUHnURXV5 M SSS5 M g!,(df  M=f)z5Validate existing migrations, and apply all new ones.rN) rirfrprrarYr]rtxru)r.rrprrrrrss r!r|MigratableDB.apply_migrationss &&(C ..s3M /$$&&&'BC!  $=$ c!5I((8"6)s B,, B; )r^rYr1)rrrr__doc__r rr r- staticmethodr rrarrrfriboolrmr#rprrur~rr ALLr{r|rr3r4s@r!rWrWGs4(!v!$!  S    5         )1D   6 i D  $46N6R6RSNTN&13K3O3OP9Q9r rWz(\d+)-(.+)\.(.+)\.sqlrrrr2c[RU5nUc[SU-5eUR5upEnUUU[ U5US.$)z6Parse a migration filename into a MigrationFile objectzInvalid migration filename: )rrrrr)filename_regexmatchrTgroupsr)rrrrr_rs r!_parse_migration_filenamersW   *E }&'E'PQQ Gw<  r rprc[X5HNup#USUS:wa[USUSUSS9eUSUS:wdM3[USS-US-USUSS9e U[U5S$) aGiven a list of migrations already applied to a database, and a list of migrations from the source code, validate that the applied migrations are correct and match the expected migrations. Throws an exception if any migrations are missing, out of order, or if the source hash does not match. Returns a list of all unapplied migrations, or an empty list if all migrations are applied and the database is up to date.rr)rr?r@r%/r)rrHrIN)zipr=rFr)rpr db_migrationsource_migrations r!rrs+.m*O&  "&6y&A A* '' 2/ :   #3F#; ;'!%(3.j1II$V,,V4 +P S/1 22r rhash_algcZ^UR5Vs/sHFnURRS5(dM%[URURU5PMH nn[ [ U4SjU55n[ USS9nUVs/sHn[XR5PM sn$s snfs snf)zcReturn a list of all migration present in the given directory, in ascending order. Filter by scope.z.sqlc>UST:H$)Nrr)frs r!!find_migrations..s!G*"5r c US$)Nrr)rs r!rrs) r )key)iterdirrendswithrlistfiltersorted_read_migration_file)rrrtfilesrs ` r!rrs A 66??6 " 7!#((AFFA6   5u= >E 54 5E7< =u!  -u ==  >s$B#%B# B(filec ZSU;dUSR5(d#[SUSSUSSUSSUS 35eUSR5nUS :Xaz[RS :a2[ R "URS 5S S9R5O2[ R "URS 55R5nOCUS:Xa4[ R"URS 55R5nO [US9eUUUSUSUS USS.$)zRead a migration filerz No migration file found for dir rz with filename rz and scope rz at version rmd5) zutf-8F)usedforsecuritysha256)rP)r%r&rrrr) is_fileFileNotFoundError read_textsys version_infohashlibrencode hexdigestrrN)rrr&r%s r!rrsN Tf!5!5!7!7.tE{m?4PZK[J\\ghlmthugvwCDHIRDSCT U   v, "C56) KK 7+U C M M OSZZ01;;= X ~~cjj12<<>8,,E{$ ?g  r )r)'rtypingrtyping_extensionsrrimportlib_resources.abcrrerchromadb.db.baserrabcr chromadb.configr r chromadb.telemetry.opentelemetryr r rrr# Exceptionr(r6r=rFrNrTrWcompilerrrrrrrr r!rsK 4/ *,I  A9A  y  y  I EyE  y k95k9`45 #."3I&3 *3i3B38 >  >  >,/ > i >} r