summaryrefslogtreecommitdiff
path: root/services/data-collector/src/data_collector/binance_ws.py
diff options
context:
space:
mode:
authorTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-01 16:24:30 +0900
committerTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-01 16:24:30 +0900
commit100aa624ad3f8ad466a95f9da8af30f31f77cc9c (patch)
treeef81b9f37872ed462a1f84ea238a130f758782d2 /services/data-collector/src/data_collector/binance_ws.py
parent73eaf704584e5bf3c4499ccdd574af87304e1e5f (diff)
fix: resolve lint issues and final integration fixes
- Fix ambiguous variable name in binance_rest.py - Remove unused volumes variable in volume_profile_strategy.py - Fix import ordering in backtester main.py and test_metrics.py - Auto-format all files with ruff
Diffstat (limited to 'services/data-collector/src/data_collector/binance_ws.py')
-rw-r--r--services/data-collector/src/data_collector/binance_ws.py5
1 files changed, 2 insertions, 3 deletions
diff --git a/services/data-collector/src/data_collector/binance_ws.py b/services/data-collector/src/data_collector/binance_ws.py
index 7a4bad2..a1c81d6 100644
--- a/services/data-collector/src/data_collector/binance_ws.py
+++ b/services/data-collector/src/data_collector/binance_ws.py
@@ -1,4 +1,5 @@
"""Binance WebSocket client for real-time kline/candle data."""
+
import asyncio
import json
import logging
@@ -96,9 +97,7 @@ class BinanceWebSocket:
except Exception:
if not self._running:
break
- logger.warning(
- "WebSocket disconnected. Reconnecting in %ds…", RECONNECT_DELAY
- )
+ logger.warning("WebSocket disconnected. Reconnecting in %ds…", RECONNECT_DELAY)
await asyncio.sleep(RECONNECT_DELAY)
def stop(self) -> None: