diff --git a/piker/brokers/binance/feed.py b/piker/brokers/binance/feed.py
index 79e5cbeb..a3e1f091 100644
--- a/piker/brokers/binance/feed.py
+++ b/piker/brokers/binance/feed.py
@@ -102,12 +102,12 @@ class AggTrade(Struct, frozen=True):
     a: int  # Aggregate trade ID
     p: float  # Price
     q: float  # Quantity with all the market trades
-    nq: float # Normal quantity without the trades involving RPI orders
     f: int  # First trade ID
     l: int  # noqa Last trade ID
     T: int  # Trade time
     m: bool  # Is the buyer the market maker?
-    M: bool | None = None  # Ignore
+    M: bool|None = None  # Ignore
+    nq: float|None = None # Normal quantity without the trades involving RPI orders
 
 
 async def stream_messages(