diff options
| author | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 16:07:20 +0900 |
|---|---|---|
| committer | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 16:07:20 +0900 |
| commit | 86a0fa84ca6662ca931182880523c0b87f617f73 (patch) | |
| tree | f483d39698849a6d4cdbd4c79979217f05be78be /services/news-collector/src/news_collector | |
| parent | 4747400168279c6cfc1196d86ec77b5d7b513c61 (diff) | |
- Add asyncio.Lock to StockSelector._ensure_session() to prevent race condition
- Remove unused HEALTH_PORT_OFFSET constant from news-collector
- Auto-fix import sorting and formatting from ruff
Diffstat (limited to 'services/news-collector/src/news_collector')
| -rw-r--r-- | services/news-collector/src/news_collector/main.py | 3 |
1 files changed, 0 insertions, 3 deletions
diff --git a/services/news-collector/src/news_collector/main.py b/services/news-collector/src/news_collector/main.py index 7265f00..c39fa67 100644 --- a/services/news-collector/src/news_collector/main.py +++ b/services/news-collector/src/news_collector/main.py @@ -25,9 +25,6 @@ from shared.sentiment import SentimentAggregator from shared.sentiment_models import MarketSentiment from shared.shutdown import GracefulShutdown -# Health check port: base + 4 -HEALTH_PORT_OFFSET = 4 - async def run_collector_once(collector, db: Database, broker: RedisBroker) -> int: """Run a single collector, store results in DB, publish to Redis. |