pikers
/
piker
4
1
Fork 0
Code Issues 10 Pull Requests 14 Packages Projects Releases Wiki Activity

`accouning.calc`: enable crash handlers on `debug_mode` input (via test harness)

qt_w_graceful_SIGINT
Tyler Goodlet 2025-09-29 15:14:35 -04:00
parent 56b660fe34
commit f2ae3b0e2e
1 changed files with 10 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
piker/accounting/calc.py
View File

@ -32,6 +32,7 @@ from typing import (
TYPE_CHECKING, TYPE_CHECKING,
) )
from tractor.devx import maybe_open_crash_handler
import polars as pl import polars as pl
from pendulum import ( from pendulum import (
DateTime, DateTime,
@ -290,15 +291,13 @@ def iter_by_dt(
# XXX: should never get here.. # XXX: should never get here..
else: else:
if debug: with maybe_open_crash_handler(pdb=True):
import tractor raise ValueError(
with tractor.devx.maybe_open_crash_handler(): f'Invalid txn time ??\n'
raise ValueError( f'txn-id: {k!r}\n'
f'Invalid txn time ??\n' f'{k!r}: {v!r}\n'
f'txn-id: {k!r}\n' )
f'{k!r}: {v!r}\n' # assert v is not None, f'No valid value for `{k}`!?'
)
# assert v is not None, f'No valid value for `{k}`!?'
if _invalid is not None: if _invalid is not None:
_invalid.append(tx) _invalid.append(tx)
@ -386,6 +385,7 @@ def open_ledger_dfs(
acctname: str, acctname: str,
ledger: TransactionLedger | None = None, ledger: TransactionLedger | None = None,
debug_mode: bool = False,
**kwargs, **kwargs,
@ -400,8 +400,7 @@ def open_ledger_dfs(
can update the ledger on exit. can update the ledger on exit.
''' '''
from piker.toolz import open_crash_handler with maybe_open_crash_handler(pdb=debug_mode):
with open_crash_handler():
if not ledger: if not ledger:
import time import time
from ._ledger import open_trade_ledger from ._ledger import open_trade_ledger