From 84cab1327d85211c511411ad795129ead7b7fd42 Mon Sep 17 00:00:00 2001 From: Tyler Goodlet Date: Tue, 5 Jul 2022 11:25:40 -0400 Subject: [PATCH] Drop uneeded count-sequencec verification --- piker/brokers/kraken/broker.py | 8 +------- 1 file changed, 1 insertion(+), 7 deletions(-) diff --git a/piker/brokers/kraken/broker.py b/piker/brokers/kraken/broker.py index c8f110b9..5a248851 100644 --- a/piker/brokers/kraken/broker.py +++ b/piker/brokers/kraken/broker.py @@ -328,8 +328,6 @@ async def trades_dialogue( ids, ) - count: int = 0 - # process and relay trades events to ems # https://docs.kraken.com/websockets/#message-ownTrades async for msg in stream_messages(ws): @@ -339,11 +337,6 @@ async def trades_dialogue( 'ownTrades', {'sequence': seq}, ]: - # XXX: do we actually need this orrr? - # ensure that we are only processing new trades? - assert seq > count - count += 1 - # flatten msgs for processing trades = { tid: trade @@ -471,6 +464,7 @@ async def trades_dialogue( 'userref': reqid, **rest, + # XXX: eg. of remaining msg schema: # 'avg_price': _, # 'cost': _, # 'descr': {