JiddlmZ ddlmZddlZddlZddlZddl m Z m Z eje ZdZej dej"Zd dZd dZd d Zy#e$r ddlmZY_wxYw) ) annotations) TraversableN) import_module resourcesz"workflows.server.sqlite.migrationsz!pragma\s+user_version\s*=\s*(\d+)ctt}tj|}d|j D}t |dS)z:Yield packaged SQL migration files in lexicographic order.c3XK|]"}|jjds|$yw)z.sqlN)nameendswith).0ps q/var/www/html/BankruptcyAI-uat/bankruptcy-ai/venv/lib/python3.12/site-packages/workflows/server/sqlite/migrate.py z(_iter_migration_files..s B1!&&//&*AQ Bs **c|jS)N)r )r s r z'_iter_migration_files..s qvv)key)r_MIGRATIONS_PKGrfilesiterdirsorted)pkgrootrs r _iter_migration_filesrs8  (C ??3 D B  BE %- ..rc|r|jdnd}tj|}|rt|j dSdS)zGReturn target schema version declared in the first PRAGMA line, if any.rN) splitlines_USER_VERSION_PATTERNsearchintgroup)sql_text first_linematchs r _parse_target_versionr%sC-5$$&q)2J ! ( ( 4E"'3u{{1~ 1T1rc|j}|jdj}|rt|dnd}t D]p}|j }t |xsd}||kr( tjd|j||jd|z|jd|}ry#t$r8}tjd|j||jdd}~wwxYw) zApply pending migrations found under the migrations package. Each migration file should start with a `PRAGMA user_version=N;` line. Files are applied in lexicographic order and only when N > current_version. zPRAGMA user_versionru+Applying migration %s → target version %szBEGIN; COMMITzFailed migration %s: %sROLLBACKN) cursorexecutefetchoner r read_textr%loggerdebugr executescript Exceptionerror)conncurcurrent_version_rowcurrent_versionpathr"target_versionexcs r run_migrationsr9"s ++-C++&;<EEG5Hc-a01aO%'->>#.x8=A _ ,  - LL=tyy.    j83 4 KK !,O#-  LL2DIIs C KK #  s55C D 3C<<D)returnzlist[Traversable])r"strr:z int | None)r2zsqlite3.Connectionr:None) __future__rimportlib.resources.abcr ImportError importlib.abcloggingresqlite3 importlibrr getLogger__name__r-rcompile IGNORECASErrr%r9rr rJsr"*3 .   8 $7" #GW/2-;*)*sA A.-A.