From 9e8d32cdfff4450a391eb2c7087555deae10c4a5 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
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 85d1f802..cdea73fc 100644
--- a/piker/brokers/kraken/broker.py
+++ b/piker/brokers/kraken/broker.py
@@ -329,8 +329,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):
@@ -340,11 +338,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
@@ -472,6 +465,7 @@ async def trades_dialogue(
                                     'userref': reqid,
                                     **rest,
 
+                                    # XXX: eg. of remaining msg schema:
                                     # 'avg_price': _,
                                     # 'cost': _,
                                     # 'descr': {