summaryrefslogtreecommitdiff
path: root/services/data-collector/src
diff options
context:
space:
mode:
authorTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-02 10:13:10 +0900
committerTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-02 10:13:10 +0900
commite9c791ae2b14884f8f0525da5fcaa1710ca1fc63 (patch)
tree752c219a95abe7bdbfbf0644711f7dede407aa7b /services/data-collector/src
parent35120795147adf53de59b7f2a3c8aa14adec9a56 (diff)
refactor: complete US stock migration
- 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/data-collector/src')
-rw-r--r--services/data-collector/src/data_collector/config.py1
-rw-r--r--services/data-collector/src/data_collector/main.py3
2 files changed, 3 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,