break ohlcv waiting upon stop signal

enarjord · Sep 24, 2024 · 9832b62 · 9832b62
1 parent 45d9cdb
commit 9832b62
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/passivbot.py b/src/passivbot.py
@@ -342,7 +342,10 @@ def get_last_position_changes(self, symbol=None):
     async def wait_for_ohlcvs_1m_to_update(self):
         await asyncio.sleep(1.0)
         prev_print_ts = utc_ms() - 5000.0
-        while self.n_symbols_missing_ohlcvs_1m > self.max_n_concurrent_ohlcvs_1m_updates - 1:
+        while (
+            not self.stop_signal_received
+            and self.n_symbols_missing_ohlcvs_1m > self.max_n_concurrent_ohlcvs_1m_updates - 1
+        ):
             if utc_ms() - prev_print_ts > 1000 * 10:
                 logging.info(
                     f"Waiting for ohlcvs to be refreshed. Number of symbols with "