+ „WÝjgãóö€Rt^RIHt^RIt^RIt^RIt^RIHt^RIH t H t RRRRR R R R R ]PR RR^RR/RRllt ]PRR /RRll4tRRlt]PRRl4tR#)uÍShared SQLite primitives for the small per-profile / board stores. ``open_db`` is the one connect + PRAGMA stack; ``transaction`` is the one commit-and-ALWAYS-close shape. Every hand-rolled ``_connect``/``_transaction`` pair used to re-carry the #69567 fix (a ``with conn:`` only commits — it never closes, so each call leaked a connection and its WAL/SHM fds until GC, exhausting ``RLIMIT_NOFILE`` on long-running gateways) and at least one copy missed it. )Ú annotationsN)ÚPath)ÚCallableÚIteratorÚbusy_timeout_msiˆÚwalTÚ foreign_keysFÚsynchronous_fullÚ row_factoryÚcheck_same_threadÚwal_lock_retriesÚ initializecó@€V^8„dQhRRRRRRRRR RR RR RR RR RRR/ #)éÚpathz Path | strÚdb_labelÚstrrÚintrÚboolrr r r r z+Callable[[sqlite3.Connection], None] | NoneÚreturnúsqlite3.Connection©)Úformats"ÚJC:\Users\johnn\AppData\Local\hermes\hermes-agent\hermes_cli\sqlite_util.pyÚ __annotate__rsn€÷1ñ1Ø ð1ðð1ðð 1ð ð 1ð ð 1ðð1ðð1ðð1ð<ð1ðñ1óc óÔ€^RIHp \V4pVPP RRR7\ P !WR, VR7p WknV PR\V4 24V'd\V4F p V !W±R7M V'dV PR 4V'dV PR 4V e V !V 4V # \ Pd]p \T 4P4R8wgT ^,T8Xdh\P!R ^T ,,4R p ? K½R p ? ii;i \ dT P#4hi;i) u­Open ``path`` (parent created), apply the PRAGMA set, run ``initialize``; closed if anything raises. ``busy_timeout_ms`` is the single busy knob: it is passed as ``connect(timeout=)`` AND set as the explicit PRAGMA so it is observable. ``wal=True`` goes through ``apply_wal_with_fallback`` — the only journal-mode setter that carries the WAL-reset-bug gate, the network-FS silent-refusal fallback and the never-live-downgrade invariant; a raw ``PRAGMA journal_mode=WAL`` bypasses all three. Only the transient ``database is locked`` from that pragma is retried (``wal_lock_retries``): a first opener initializing a shared DB can make it ignore the busy timeout, notably on Windows. )Úapply_wal_with_fallbackT)ÚparentsÚexist_okiè)Útimeoutr zPRAGMA busy_timeout=)rzdatabase is lockedg{®Gáz„?NzPRAGMA foreign_keys=ONzPRAGMA synchronous=FULL)Úhermes_state_walrrÚparentÚmkdirÚsqlite3Úconnectr ÚexecuterÚrangeÚOperationalErrorrÚlowerÚtimeÚsleepÚ BaseExceptionÚclose)rrrrrr r r r r rÚconnÚattemptÚexcs&$$$$$$$$$ rÚopen_dbr1s+€õ,9ä ‹:€D؇KK×јd¨TÐÔ2ä ?Š?˜4¸4Õ)?ÐSdÔ e€DðØ&ÔØ ‰ Ð+¬C°Ó,@Ð+AÐBÔCß Ü Ð!1Ö2ð4Ù+¨DÕDÙñ3÷ Ø L‰LÐ1Ô 2ß Ø L‰LÐ2Ô 3Ø Ò !Ù tÔ ð €Køô×/Ñ/ô4ܘ3“x—~‘~Ó'Ð+?Ô?À7ÈQÅ;ÐRbÔCbØÜ—J’J˜t q¨'¥zÕ2×3Ò3ûð4ûô ôØ ‰ Œ Ø ðúsCÁ9E  C E ÂE Â7E ÃEÃ+AEÄ<E ÅEÅE Å E'Ú immediatecó$€V^8„dQhRRRRRR/#)rr.rr2rrzIterator[sqlite3.Connection]r)rs"rrrGs#€÷ñÐ(ð¸ðÐIeñrc#óà"€V'dVPR4V;_uu_4Vx€RRR4VP4R# +'giL";i TP4i;i5i)z\Commit on success, roll back on error, and ALWAYS close ``conn`` (see the module docstring).úBEGIN IMMEDIATEN)r&r-)r.r2s&$rÚ transactionr6FsGé€ðß Ø L‰LÐ*Ô +ß ŠTØŠJ÷ð ‰ Ž ÷Tûð ‰ üs1‚A.„#A§A¬A´A.Á A ÁAÁA+Á+A.c ó,€V^8„dQhRRRRRRRRRR/#) rr.rÚtablerÚcolumnÚddlrrr)rs"rrrRs2€÷ ñ Ð 2ð ¸3ð Èð ÐRUð ÐZ^ñ rcóº€VPRV RV 24R# \Pd+pR\T4P 49dRp?R#hRp?ii;i)a``ALTER TABLE ADD COLUMN ``, idempotent across races: True when this call added it, False on the ``duplicate column name`` a concurrent migrator caused. ``column`` is the human-readable name for the call site; ``ddl`` carries the actual definition. See #21708. z ALTER TABLE z ADD COLUMN Tzduplicate column nameNF)r&r$r(rr))r.r8r9r:r0s&&&& rÚadd_column_if_missingr<RsR€ðØ ‰ | E 7¨,°s°eÐ<Ô=ÙøÜ × #Ñ #ôØ "¤c¨#£h§n¡nÓ&6Ô 6ÝØ ûðús‚›A°AÁAÁAcó€V^8„dQhRR/#)rr.rr)rs"rrrcs€÷ñÐ&ñrc#óÖ"€VPR4Vx€VPR4R# \d0TPR4h \Pdhi;ii;i5i)zÞAn IMMEDIATE write transaction on a long-lived connection (stays open). The explicit ROLLBACK is guarded so a SQLite auto-rollback (no transaction left under EIO / contention / corruption) cannot shadow the original error.r5ÚCOMMITÚROLLBACKN)r&Ú Exceptionr$r()r.s&rÚ write_txnrBbsoé€ð  ‡LLÐ"Ô#ð ØŠ ð ‰ XÖøô ôð Ø L‰L˜Ô $ð øô×'Ñ'ô Ø Ø ð úðüs<‚A)•,™A)¬ A&¸A Á A&Á A"ÁA&Á!A"Á"A&Á&A))Ú__doc__Ú __future__rÚ contextlibr$r*ÚpathlibrÚtypingrrÚRowr1Úcontextmanagerr6r<rBrrrÚrJs¹ðñõ#ãÛÛ Ýß%ð1ð ð 1ð ð 1ð ð 1ð#ð1ð— ‘ ð1ð#ð1ðð1ð?C÷1ðh ×Ñð¸uöóðõ ð  ×Ñôóòr