From 98de80bf71dbc08c353e167550d2dac25a80c8b8 Mon Sep 17 00:00:00 2001 From: Guillaume De Saint Martin Date: Fri, 20 Mar 2026 15:02:52 +0100 Subject: [PATCH] [Exchanges] fix get_extended_additional_connector_config in ws call --- .../exchanges/connectors/ccxt/ccxt_connector.py | 3 +++ .../exchanges/connectors/ccxt/ccxt_websocket_connector.py | 8 ++++---- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_connector.py b/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_connector.py index 03b84397c..c38400814 100644 --- a/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_connector.py +++ b/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_connector.py @@ -342,6 +342,9 @@ def add_options(self, options_dict): @classmethod def get_extended_additional_connector_config(cls, additional_config: dict): + """ + implement in subclass if necessary + """ extended_ccxt_options = {} if extended_ccxt_options: if additional_config and ccxt_constants.CCXT_OPTIONS in additional_config: diff --git a/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_websocket_connector.py b/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_websocket_connector.py index 7a0b125da..6cfcf02b7 100644 --- a/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_websocket_connector.py +++ b/packages/trading/octobot_trading/exchanges/connectors/ccxt/ccxt_websocket_connector.py @@ -141,10 +141,10 @@ def __init__( additional_config ) if self.USE_REST_CONNECTOR_ADDITIONAL_CONFIG: - self.additional_config = { - **(self.additional_config or {}), - **self.exchange_manager.exchange.get_extended_additional_connector_config() - } + self.additional_config = ( + self.exchange_manager.exchange.connector.get_extended_additional_connector_config(self.additional_config) + if self.exchange_manager.exchange.connector else self.additional_config + ) self.headers: dict[str, str] = {} self.options: dict[str, typing.Any] = { "newUpdates": True, # only get new updates from trades and ohlcv (don't return the full cached history)