diff options
| author | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 10:13:10 +0900 |
|---|---|---|
| committer | TheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com> | 2026-04-02 10:13:10 +0900 |
| commit | e9c791ae2b14884f8f0525da5fcaa1710ca1fc63 (patch) | |
| tree | 752c219a95abe7bdbfbf0644711f7dede407aa7b /services | |
| parent | 35120795147adf53de59b7f2a3c8aa14adec9a56 (diff) | |
- Data collector: Alpaca REST polling (replaces Binance WebSocket)
- Order executor: Alpaca submit_order (replaces ccxt)
- Claude stock screener: daily MOC candidate analysis
- Remove ccxt/websockets dependencies
- Default universe: AAPL, MSFT, GOOGL, AMZN, TSLA + 28 more
- 399 tests passing, lint clean
Diffstat (limited to 'services')
| -rw-r--r-- | services/data-collector/src/data_collector/config.py | 1 | ||||
| -rw-r--r-- | services/data-collector/src/data_collector/main.py | 3 | ||||
| -rw-r--r-- | services/order-executor/src/order_executor/main.py | 1 |
3 files changed, 4 insertions, 1 deletions
diff --git a/services/data-collector/src/data_collector/config.py b/services/data-collector/src/data_collector/config.py index 4761013..dd430e6 100644 --- a/services/data-collector/src/data_collector/config.py +++ b/services/data-collector/src/data_collector/config.py @@ -1,4 +1,5 @@ """Data Collector configuration.""" + from shared.config import Settings diff --git a/services/data-collector/src/data_collector/main.py b/services/data-collector/src/data_collector/main.py index 38f8759..b42b34c 100644 --- a/services/data-collector/src/data_collector/main.py +++ b/services/data-collector/src/data_collector/main.py @@ -1,9 +1,9 @@ """Data Collector Service — fetches US stock data from Alpaca.""" + import asyncio from shared.alpaca import AlpacaClient from shared.broker import RedisBroker -from shared.config import Settings from shared.db import Database from shared.events import CandleEvent from shared.healthcheck import HealthCheckServer @@ -33,6 +33,7 @@ async def fetch_latest_bars( bar = bars[-1] from datetime import datetime from decimal import Decimal + candle = Candle( symbol=symbol, timeframe=timeframe, diff --git a/services/order-executor/src/order_executor/main.py b/services/order-executor/src/order_executor/main.py index 3e098c3..51ab286 100644 --- a/services/order-executor/src/order_executor/main.py +++ b/services/order-executor/src/order_executor/main.py @@ -1,4 +1,5 @@ """Order Executor Service entry point.""" + import asyncio from decimal import Decimal |
