fix: harden ledger skip invariant
Co-authored-by: genichin <4282227+genichin@users.noreply.github.com>
This commit is contained in:
co-authored by
genichin
parent
76cde2edd0
commit
b88b21b772
@@ -98,7 +98,8 @@ class PostgreSQLLedgerSkipStore:
|
|||||||
)
|
)
|
||||||
conn.commit()
|
conn.commit()
|
||||||
record = self.get(skip_key)
|
record = self.get(skip_key)
|
||||||
assert record is not None
|
if record is None:
|
||||||
|
raise RuntimeError(f"ledger_skip row missing after upsert for key {skip_key!r}")
|
||||||
return record, notify
|
return record, notify
|
||||||
|
|
||||||
def get(self, skip_key: str) -> LedgerSkipRecord | None:
|
def get(self, skip_key: str) -> LedgerSkipRecord | None:
|
||||||
|
|||||||
Reference in New Issue
Block a user