summaryrefslogtreecommitdiff
path: root/services/data-collector/src/data_collector
diff options
context:
space:
mode:
Diffstat (limited to 'services/data-collector/src/data_collector')
-rw-r--r--services/data-collector/src/data_collector/main.py4
-rw-r--r--services/data-collector/src/data_collector/ws_factory.py1
2 files changed, 4 insertions, 1 deletions
diff --git a/services/data-collector/src/data_collector/main.py b/services/data-collector/src/data_collector/main.py
index b393cc2..eebe14a 100644
--- a/services/data-collector/src/data_collector/main.py
+++ b/services/data-collector/src/data_collector/main.py
@@ -57,7 +57,9 @@ async def run() -> None:
)
health = HealthCheckServer(
- "data-collector", port=config.health_port + HEALTH_PORT_OFFSET, auth_token=config.metrics_auth_token
+ "data-collector",
+ port=config.health_port + HEALTH_PORT_OFFSET,
+ auth_token=config.metrics_auth_token,
)
health.register_check("redis", broker.ping)
await health.start()
diff --git a/services/data-collector/src/data_collector/ws_factory.py b/services/data-collector/src/data_collector/ws_factory.py
index b8e2719..e068399 100644
--- a/services/data-collector/src/data_collector/ws_factory.py
+++ b/services/data-collector/src/data_collector/ws_factory.py
@@ -1,4 +1,5 @@
"""WebSocket factory for exchange-specific connections."""
+
import logging
from data_collector.binance_ws import BinanceWebSocket