From e1cad9fb05256ecfa32f17347631e57b396421b9 Mon Sep 17 00:00:00 2001 From: Carlo Eugster Date: Wed, 5 Jun 2024 17:23:27 +0200 Subject: [PATCH] Fix case missmatch for KrakenFutures symbols --- CHANGES.md | 1 + cryptofeed/exchanges/kraken_futures.py | 3 +-- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/CHANGES.md b/CHANGES.md index 99fd6d063..0842646c1 100644 --- a/CHANGES.md +++ b/CHANGES.md @@ -7,6 +7,7 @@ * Feature: Bybit spot support * Update: Bybit migrate to API V5 for public streams * Bugfix: Handle None ids for Kraken trades in QuestDB + * Bugfix: Fix case missmatch in KrakenFutures symbols ### 2.4.0 (2024-01-07) * Update: Fix tests diff --git a/cryptofeed/exchanges/kraken_futures.py b/cryptofeed/exchanges/kraken_futures.py index 4c1677a72..96ec72709 100644 --- a/cryptofeed/exchanges/kraken_futures.py +++ b/cryptofeed/exchanges/kraken_futures.py @@ -246,8 +246,7 @@ async def message_handler(self, msg: str, conn, timestamp: float): else: LOG.warning("%s: Invalid message type %s", self.id, msg) else: - # As per Kraken support: websocket product_id is uppercase version of the REST API symbols - pair = self.exchange_symbol_to_std_symbol(msg['product_id'].lower()) + pair = self.exchange_symbol_to_std_symbol(msg['product_id']) if msg['feed'] == 'trade': await self._trade(msg, pair, timestamp) elif msg['feed'] == 'trade_snapshot':