From bf4afbc0a3cc4e847ef01840365fd6a6ae9c142f Mon Sep 17 00:00:00 2001 From: TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> Date: Thu, 2 Apr 2026 15:54:55 +0900 Subject: style: auto-fix lint violations from enhanced ruff rules --- services/data-collector/src/data_collector/main.py | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) (limited to 'services/data-collector/src/data_collector') diff --git a/services/data-collector/src/data_collector/main.py b/services/data-collector/src/data_collector/main.py index 8b9f301..2d44848 100644 --- a/services/data-collector/src/data_collector/main.py +++ b/services/data-collector/src/data_collector/main.py @@ -4,6 +4,7 @@ import asyncio import aiohttp +from data_collector.config import CollectorConfig from shared.alpaca import AlpacaClient from shared.broker import RedisBroker from shared.db import Database @@ -15,8 +16,6 @@ from shared.models import Candle from shared.notifier import TelegramNotifier from shared.shutdown import GracefulShutdown -from data_collector.config import CollectorConfig - # Health check port: base + 0 HEALTH_PORT_OFFSET = 0 @@ -48,7 +47,7 @@ async def fetch_latest_bars( volume=Decimal(str(bar["v"])), ) candles.append(candle) - except (aiohttp.ClientError, ConnectionError, TimeoutError, asyncio.TimeoutError) as exc: + except (aiohttp.ClientError, ConnectionError, TimeoutError) as exc: log.warning("fetch_bar_network_error", symbol=symbol, error=str(exc)) except (ValueError, KeyError, TypeError) as exc: log.warning("fetch_bar_parse_error", symbol=symbol, error=str(exc)) @@ -98,7 +97,7 @@ async def run() -> None: # Check if market is open try: is_open = await alpaca.is_market_open() - except (aiohttp.ClientError, ConnectionError, TimeoutError, asyncio.TimeoutError): + except (aiohttp.ClientError, ConnectionError, TimeoutError): is_open = False if is_open: -- cgit v1.2.3