From 672c01f13a34736ae40ed4ea9e3a790770533665 Mon Sep 17 00:00:00 2001 From: jaredgoldman Date: Thu, 13 Apr 2023 22:35:21 -0400 Subject: [PATCH] Use trade_data_ts for trade message receival --- piker/brokers/kucoin.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/piker/brokers/kucoin.py b/piker/brokers/kucoin.py index 3cd4b1ee..98bb32a8 100644 --- 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.time, + 'brokerd_ts': trade_data_ts, 'ticks': [ { 'type': 'trade', 'price': float(trade_data.price), 'size': float(trade_data.size), - 'broker_ts': trade_data.time, + 'broker_ts': trade_data_ts, } ], }