Fix timestamp issues on coinbase ticker feed

leftys · Nov 29, 2024 · feadc9c · feadc9c
1 parent b679fc9
commit feadc9c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/cryptofeed/exchanges/coinbase.py b/cryptofeed/exchanges/coinbase.py
@@ -109,7 +109,9 @@ async def _ticker(self, msg: dict, timestamp: float):
             'last_size': '0.00241692'
         }
         '''
-        await self.callback(TICKER, Ticker(self.id, self.exchange_symbol_to_std_symbol(msg['product_id']), Decimal(msg['best_bid']), Decimal(msg['best_ask']), self.timestamp_normalize(msg['time']), raw=msg), timestamp)
+
+        ts = self.timestamp_normalize(msg['time']) if 'time' in msg else None
+        await self.callback(TICKER, Ticker(self.id, self.exchange_symbol_to_std_symbol(msg['product_id']), Decimal(msg['best_bid']), Decimal(msg['best_ask']), ts, raw=msg), timestamp)
 
     async def _book_update(self, msg: dict, timestamp: float):
         '''