diff options
| author | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 14:17:43 +0900 |
|---|---|---|
| committer | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 14:17:43 +0900 |
| commit | 35aa61c651217663406c9cd6df404f85338b2d68 (patch) | |
| tree | 9d85dd87e725984d45d7b6bdfef8b316ddfc4ae7 /services/strategy-engine/src/strategy_engine | |
| parent | 17540c99d5e28576a6642e23d7bd6b297513e2d8 (diff) | |
style: fix lint and formatting issues across news collector and shared
Diffstat (limited to 'services/strategy-engine/src/strategy_engine')
| -rw-r--r-- | services/strategy-engine/src/strategy_engine/main.py | 6 | ||||
| -rw-r--r-- | services/strategy-engine/src/strategy_engine/stock_selector.py | 13 |
2 files changed, 10 insertions, 9 deletions
diff --git a/services/strategy-engine/src/strategy_engine/main.py b/services/strategy-engine/src/strategy_engine/main.py index e9c96b2..5a30766 100644 --- a/services/strategy-engine/src/strategy_engine/main.py +++ b/services/strategy-engine/src/strategy_engine/main.py @@ -126,9 +126,9 @@ async def run() -> None: anthropic_model=config.anthropic_model, max_picks=config.selector_max_picks, ) - tasks.append(asyncio.create_task( - run_stock_selector(selector, notifier, db, config, log) - )) + tasks.append( + asyncio.create_task(run_stock_selector(selector, notifier, db, config, log)) + ) log.info("stock_selector_enabled", time=config.selector_final_time) await asyncio.gather(*tasks) diff --git a/services/strategy-engine/src/strategy_engine/stock_selector.py b/services/strategy-engine/src/strategy_engine/stock_selector.py index e1f2fe7..268d557 100644 --- a/services/strategy-engine/src/strategy_engine/stock_selector.py +++ b/services/strategy-engine/src/strategy_engine/stock_selector.py @@ -4,17 +4,14 @@ import json import logging import re from datetime import datetime, timezone -from decimal import Decimal -from typing import Optional import aiohttp -import pandas as pd from shared.alpaca import AlpacaClient from shared.broker import RedisBroker from shared.db import Database from shared.models import OrderSide -from shared.sentiment_models import Candidate, MarketSentiment, SelectedStock, SymbolScore +from shared.sentiment_models import Candidate, MarketSentiment, SelectedStock logger = logging.getLogger(__name__) @@ -325,7 +322,9 @@ class StockSelector: ema20 = sum(closes[-20:]) / 20 # simple approximation current_price = closes[-1] if current_price <= ema20: - logger.debug("%s price %.2f <= EMA20 %.2f", candidate.symbol, current_price, ema20) + logger.debug( + "%s price %.2f <= EMA20 %.2f", candidate.symbol, current_price, ema20 + ) continue avg_volume = sum(volumes[:-1]) / max(len(volumes) - 1, 1) @@ -333,7 +332,9 @@ class StockSelector: if current_volume <= 0.5 * avg_volume: logger.debug( "%s volume %.0f <= 50%% avg %.0f", - candidate.symbol, current_volume, avg_volume, + candidate.symbol, + current_volume, + avg_volume, ) continue |
