From e6dd1458f891ddde4a4f74101c2db35b8b79534f Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Thu, 27 Oct 2022 15:00:23 -0400 Subject: [PATCH] `kraken`: the apiflows chain map needs a `dict` --- piker/brokers/kraken/broker.py | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/piker/brokers/kraken/broker.py b/piker/brokers/kraken/broker.py index c1dd568b..c77f2140 100644 --- a/piker/brokers/kraken/broker.py +++ b/piker/brokers/kraken/broker.py @@ -795,7 +795,7 @@ async def handle_order_updates( # 'vol_exec': exec_vlm} # 0.0000 match update_msg: - # EMS-unknown live order that needs to be + # EMS-unknown LIVE order that needs to be # delivered and loaded on the client-side. case { 'userref': reqid, @@ -849,7 +849,7 @@ async def handle_order_updates( ), src='kraken', ) - apiflows[reqid].maps.append(status_msg) + apiflows[reqid].maps.append(status_msg.to_dict()) await ems_stream.send(status_msg) continue @@ -1104,7 +1104,6 @@ async def handle_order_updates( 'txid': [txid], }) case _: - log.warning(f'Unhandled trades update msg: {msg}')