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': {