From 4ffee0ae8badae81da3a6f276ac07380c5663b61 Mon Sep 17 00:00:00 2001 From: 21in7 Date: Mon, 2 Mar 2026 16:25:13 +0900 Subject: [PATCH] feat: run UserDataStream in parallel with candle stream Made-with: Cursor --- src/bot.py | 19 ++++++++++++++++--- 1 file changed, 16 insertions(+), 3 deletions(-) diff --git a/src/bot.py b/src/bot.py index 373a4f1..2645c42 100644 --- a/src/bot.py +++ b/src/bot.py @@ -9,6 +9,7 @@ from src.notifier import DiscordNotifier from src.risk_manager import RiskManager from src.ml_filter import MLFilter from src.ml_features import build_features +from src.user_data_stream import UserDataStream class TradingBot: @@ -272,7 +273,19 @@ class TradingBot: balance = await self.exchange.get_balance() self.risk.set_base_balance(balance) logger.info(f"기준 잔고 설정: {balance:.2f} USDT (동적 증거금 비율 기준점)") - await self.stream.start( - api_key=self.config.api_key, - api_secret=self.config.api_secret, + + user_stream = UserDataStream( + exchange=self.exchange, + on_order_filled=self._on_position_closed, + ) + + await asyncio.gather( + self.stream.start( + api_key=self.config.api_key, + api_secret=self.config.api_secret, + ), + user_stream.start( + api_key=self.config.api_key, + api_secret=self.config.api_secret, + ), )