Trigger trading pair symbol removal when not supported in options trading

Author: Herklos

CHANGELOG.md

@@ -4,6 +4,10 @@ All notable changes to this project will be documented in this file.
 The format is based on [Keep a Changelog](https://keepachangelog.com/en/1.0.0/),
 and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.html).
 
+## [2.5.6] - 2026-01-28
+### Updated
+[OHLCVUpdate] Trigger removal of unsupported traded pair when exchange trading options
+
 ## [2.5.5] - 2026-01-27
 ### Updated
 [API] Add include_additional_pairs get_trading_symbols

README.md

@@ -1,4 +1,4 @@
-# OctoBot-Trading [2.5.5](https://github.com/Drakkar-Software/OctoBot-Trading/blob/master/CHANGELOG.md)
+# OctoBot-Trading [2.5.6](https://github.com/Drakkar-Software/OctoBot-Trading/blob/master/CHANGELOG.md)
 [![Codacy Badge](https://api.codacy.com/project/badge/Grade/903b6b22bceb4661b608a86fea655f69)](https://app.codacy.com/gh/Drakkar-Software/OctoBot-Trading?utm_source=github.com&utm_medium=referral&utm_content=Drakkar-Software/OctoBot-Trading&utm_campaign=Badge_Grade_Dashboard)
 [![PyPI](https://img.shields.io/pypi/v/OctoBot-Trading.svg)](https://pypi.python.org/pypi/OctoBot-Trading/)
 [![Coverage Status](https://coveralls.io/repos/github/Drakkar-Software/OctoBot-Trading/badge.svg?branch=master)](https://coveralls.io/github/Drakkar-Software/OctoBot-Trading?branch=master)

octobot_trading/__init__.py

@@ -15,4 +15,4 @@
 #  License along with this library.
 
 PROJECT_NAME = "OctoBot-Trading"
-VERSION = "2.5.5"  # major.minor.revision
+VERSION = "2.5.6"  # major.minor.revision

octobot_trading/exchange_data/ohlcv/channel/ohlcv_updater.py

@@ -320,6 +320,7 @@ async def _candle_update_loop(self, time_frame, pair):
             except errors.UnSupportedSymbolError as err:
                 self.logger.warning(
                     f"{self.channel.exchange_manager.exchange_name} is not supporting {pair} on {time_frame.value}: {err}")
+                await self._remove_unsupported_pairs(pair)
             except errors.NotSupported as err:
                 self.logger.warning(
                     f"{self.channel.exchange_manager.exchange_name} is not supporting updates: {err}")
@@ -385,6 +386,12 @@ def _set_initialized(self, pair, time_frame, initialized):
             self.initialized_candles_by_tf_by_symbol[pair] = {}
         self.initialized_candles_by_tf_by_symbol[pair][time_frame] = initialized
 
+    async def _remove_unsupported_pairs(self, pair: str):
+        # For now only remove the pair from the traded pairs if it's an option exchange
+        if self.channel.exchange_manager.is_option:
+            self.logger.warning(f"Removing {pair} from traded pairs...")
+            self.channel.exchange_manager.exchange_config.remove_traded_symbols([pair])
+
     async def resume(self) -> None:
         await super().resume()
         if not self.is_running:

octobot_trading/exchanges/config/exchange_config_data.py

@@ -57,6 +57,9 @@ def __init__(self, exchange_manager):
         # list of exchange supported pairs on which we want to collect data through updaters or websocket
         self.additional_traded_pairs: list[str] = []
 
+        # list of exchange supported pairs that have been removed from the traded_symbol_pairs or additional_traded_pairs
+        self.removed_traded_pairs: list[str] = []
+
         # list of required time frames from configuration that are available
         self.available_required_time_frames: list[commons_enums.TimeFrames] = []
 
@@ -167,6 +170,11 @@ async def add_traded_symbols(self, symbols: list[str], time_frames: list[commons
             added_pairs=symbols, removed_pairs=[], added_time_frames=time_frames, watch_only=False
         )
 
+    async def remove_traded_symbols(self, symbols: list[str]):
+        await self.update_traded_symbol_pairs(
+            added_pairs=[], removed_pairs=symbols, added_time_frames=[], watch_only=False
+        )
+
     async def update_traded_symbol_pairs(
         self,
         added_pairs: list[str],
@@ -200,16 +208,16 @@ async def update_traded_symbol_pairs(
             and self._is_valid_symbol(symbol_pair, [])
             and symbol_pair not in self.traded_symbol_pairs 
             and symbol_pair not in self.additional_traded_pairs 
+            and symbol_pair not in self.removed_traded_pairs
             and (not watch_only or symbol_pair not in self.watched_pairs)
         ]
         removed_valid_symbol_pairs = [
             symbol_pair
             for symbol_pair in removed_pairs
             if symbols_util.is_symbol(symbol_pair) 
             and self._is_valid_symbol(symbol_pair, [])
-            and symbol_pair in self.traded_symbol_pairs 
-            and symbol_pair in self.additional_traded_pairs 
-            and (not watch_only or symbol_pair in self.watched_pairs)
+            and (symbol_pair in self.traded_symbol_pairs or symbol_pair in self.additional_traded_pairs or (not watch_only or symbol_pair in self.watched_pairs))
+            and symbol_pair not in self.removed_traded_pairs
         ]
         new_valid_time_frames = [
             time_frame
@@ -268,6 +276,12 @@ async def update_traded_symbol_pairs(
                     await channel.modify(
                         added_pairs=new_valid_symbol_pairs, removed_pairs=removed_valid_symbol_pairs
                     )
+
+            if removed_valid_symbol_pairs:
+                self.traded_symbol_pairs = [pair for pair in self.traded_symbol_pairs if pair not in removed_valid_symbol_pairs]
+                self.additional_traded_pairs = [pair for pair in self.additional_traded_pairs if pair not in removed_valid_symbol_pairs]
+                self.watched_pairs = [pair for pair in self.watched_pairs if pair not in removed_valid_symbol_pairs]
+                self.removed_traded_pairs += removed_valid_symbol_pairs
         except Exception as e:
             self._logger.exception(e, True, f"Failed to update {'watched' if watch_only else 'traded'} symbol pairs {added_pairs} and {removed_pairs} : {e}")
 

tests/exchanges/test_exchange_config_data.py

@@ -336,7 +336,32 @@ async def test_update_traded_symbol_pairs(self, watch_only, added_pairs, removed
                 assert f"Ignored additional time frames for watched pairs" in logger_mock.error.call_args[0][0]
             else:
                 assert logger_mock.error.call_count == 0
-            
+
+            # Test removed_traded_pairs
+            if removed_pairs:
+                # removed pairs should be tracked
+                assert exchange_manager.exchange_config.removed_traded_pairs == removed_pairs
+
+                # calling again with the same pairs should not change state for removed pairs
+                before_second_call_removed = list(exchange_manager.exchange_config.removed_traded_pairs)
+                await exchange_manager.exchange_config.update_traded_symbol_pairs(
+                    added_pairs=removed_pairs,
+                    removed_pairs=removed_pairs,
+                    added_time_frames=added_time_frames,
+                    watch_only=watch_only,
+                )
+                # removed_traded_pairs should remain unchanged
+                assert exchange_manager.exchange_config.removed_traded_pairs == before_second_call_removed
+                for pair in removed_pairs:
+                    # removed pairs should not re-appear in additional_traded_pairs
+                    assert pair not in exchange_manager.exchange_config.additional_traded_pairs
+                    # and should not re-appear in watched_pairs for watch_only mode
+                    if watch_only:
+                        assert pair not in exchange_manager.exchange_config.watched_pairs
+            else:
+                # no removed pairs: tracking list must stay empty
+                assert exchange_manager.exchange_config.removed_traded_pairs == []
+
             cancel_ccxt_throttle_task()
         finally:
             await exchange_manager.stop()