From 1cc37673a432fcb7f885173fe6f10912c3fc4869 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 30 Mar 2023 17:25:44 -0400 Subject: [PATCH] `ib`: drop pp mismatch err block, we already do it in audit routine --- piker/brokers/ib/broker.py | 22 +++------------------- 1 file changed, 3 insertions(+), 19 deletions(-) diff --git a/piker/brokers/ib/broker.py b/piker/brokers/ib/broker.py index 7c42cf37..add03cc1 100644 --- a/piker/brokers/ib/broker.py +++ b/piker/brokers/ib/broker.py @@ -683,23 +683,6 @@ async def trades_dialogue( assert msg.account in accounts, ( f'Position for unknown account: {msg.account}') - ledger: dict = ledgers[acctid] - table: PpTable = tables[acctid] - pp: Position = table.pps.get(bs_mktid) - - if ( - not pp - or pp.size != msg.size - ): - pp = table.pps[bs_mktid] - pairinfo = pp.symbol - if msg.size != pp.size: - log.error( - f'Pos size mismatch {pairinfo.fqsn}:\n' - f'ib: {msg.size}\n' - f'piker: {pp.size}\n' - ) - # iterate all (newly) updated pps tables for every # client-account and build out position msgs to deliver to # EMS. @@ -802,13 +785,14 @@ async def emit_pp_update( active, closed = table.dump_active() # NOTE: update ledger with all new trades - for acctid, trades_by_id in api_to_ledger_entries.items(): + for fq_acctid, trades_by_id in api_to_ledger_entries.items(): + acctid = fq_acctid.strip('ib.') ledger = ledgers[acctid] for tid, tdict in trades_by_id.items(): # NOTE: don't override flex/previous entries with new API # ones, just update with new fields! - ledger.setdefaults(tid, {}).update(tdict) + ledger.setdefault(tid, {}).update(tdict) # generate pp msgs and cross check with ib's positions data, relay # re-formatted pps as msgs to the ems.