From 60390ae59673376bdb98a57487b03c61db1098a7 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 13 Feb 2025 10:46:44 -0500 Subject: [PATCH] Various `.clearing` todos/notes on potential issues with loglevel settings.. --- piker/clearing/_client.py | 6 +++++- piker/clearing/_paper_engine.py | 2 ++ piker/clearing/_util.py | 1 + 3 files changed, 8 insertions(+), 1 deletion(-) diff --git a/piker/clearing/_client.py b/piker/clearing/_client.py index 9bb2aa74..6d8f645e 100644 --- a/piker/clearing/_client.py +++ b/piker/clearing/_client.py @@ -168,7 +168,6 @@ class OrderClient(Struct): async def relay_orders_from_sync_code( - client: OrderClient, symbol_key: str, to_ems_stream: tractor.MsgStream, @@ -242,6 +241,11 @@ async def open_ems( async with maybe_open_emsd( broker, + # XXX NOTE, LOL so this determines the daemon `emsd` loglevel + # then FYI.. that's kinda wrong no? + # -[ ] shouldn't it be set by `pikerd -l` or no? + # -[ ] would make a lot more sense to have a subsys ctl for + # levels.. like `-l emsd.info` or something? loglevel=loglevel, ) as portal: diff --git a/piker/clearing/_paper_engine.py b/piker/clearing/_paper_engine.py index 0393b2e6..e303d76c 100644 --- a/piker/clearing/_paper_engine.py +++ b/piker/clearing/_paper_engine.py @@ -297,6 +297,8 @@ class PaperBoi(Struct): # transmit pp msg to ems pp: Position = self.acnt.pps[bs_mktid] + # TODO, this will break if `require_only=True` was passed to + # `.update_from_ledger()` pp_msg = BrokerdPosition( broker=self.broker, diff --git a/piker/clearing/_util.py b/piker/clearing/_util.py index 962861e8..c82a01aa 100644 --- a/piker/clearing/_util.py +++ b/piker/clearing/_util.py @@ -30,6 +30,7 @@ subsys: str = 'piker.clearing' log = get_logger(subsys) +# TODO, oof doesn't this ignore the `loglevel` then??? get_console_log = partial( get_console_log, name=subsys,