Start an IMMEDIATE transaction, rolling back any prior uncommitted transaction first (regression guard for #135 / #489).
(self)
| 261 | self._invalidate_cache() |
| 262 | |
| 263 | def _begin_immediate(self) -> None: |
| 264 | """Start an IMMEDIATE transaction, rolling back any prior uncommitted |
| 265 | transaction first (regression guard for #135 / #489). |
| 266 | """ |
| 267 | if self._conn.in_transaction: |
| 268 | logger.warning("Rolling back uncommitted transaction before BEGIN IMMEDIATE") |
| 269 | self._conn.rollback() |
| 270 | self._conn.execute("BEGIN IMMEDIATE") |
| 271 | |
| 272 | def store_file_nodes_edges( |
| 273 | self, file_path: str, nodes: list[NodeInfo], edges: list[EdgeInfo], fhash: str = "" |
no test coverage detected