Fix typo with ts vars

2023-04-13 22:37:17 -04:00 · 2023-04-13 22:37:17 -04:00 · 4f576b6f36
parent 672c01f13a
commit 4f576b6f36
1 changed files with 2 additions and 2 deletions
--- a/piker/brokers/kucoin.py
+++ b/piker/brokers/kucoin.py
@ -586,13 +586,13 @@ async def stream_messages(ws: NoBsWs, sym: str) -> AsyncGenerator[NoBsWs, dict]:
                    yield 'trade', {
                        'symbol': sym,
                        'last': trade_data.price,
-                        'brokerd_ts': trade_data_ts,
+                        'brokerd_ts': last_trade_ts,
                        'ticks': [
                            {
                                'type': 'trade',
                                'price': float(trade_data.price),
                                'size': float(trade_data.size),
-                                'broker_ts': trade_data_ts,
+                                'broker_ts': last_trade_ts,
                            }
                        ],
                    }