From 117fd9e6bc3cc8c6d2820072c58407481764ce5a Mon Sep 17 00:00:00 2001
From: 21in7 <skawksmsduzo@gmail.com>
Date: Sun, 1 Mar 2026 13:04:02 +0900
Subject: [PATCH] =?UTF-8?q?fix:=20AsyncClient.futures=5Fklines=20await=20?=
 =?UTF-8?q?=EB=88=84=EB=9D=BD=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

Made-with: Cursor
---
 src/data_stream.py        | 12 ++++--------
 tests/test_data_stream.py |  2 +-
 2 files changed, 5 insertions(+), 9 deletions(-)

diff --git a/src/data_stream.py b/src/data_stream.py
index 46117ae..a5c2509 100644
--- a/src/data_stream.py
+++ b/src/data_stream.py
@@ -48,14 +48,10 @@ class KlineStream:
     async def _preload_history(self, client: AsyncClient, limit: int = 200):
         """REST API로 과거 캔들 데이터를 버퍼에 미리 채운다."""
         logger.info(f"과거 캔들 {limit}개 로드 중...")
-        loop = asyncio.get_event_loop()
-        klines = await loop.run_in_executor(
-            None,
-            lambda: client.futures_klines(
-                symbol=self.symbol.upper(),
-                interval=self.interval,
-                limit=limit,
-            ),
+        klines = await client.futures_klines(
+            symbol=self.symbol.upper(),
+            interval=self.interval,
+            limit=limit,
         )
         # 마지막 캔들은 아직 닫히지 않았을 수 있으므로 제외
         for k in klines[:-1]:
diff --git a/tests/test_data_stream.py b/tests/test_data_stream.py
index 82a6fa0..26b2ed4 100644
--- a/tests/test_data_stream.py
+++ b/tests/test_data_stream.py
@@ -57,7 +57,7 @@ async def test_preload_history_fills_buffer():
         for i in range(201)  # 201개 반환 → 마지막 1개 제외 → 200개 버퍼
     ]
 
-    mock_client = MagicMock()
+    mock_client = AsyncMock()
     mock_client.futures_klines.return_value = fake_klines
 
     await stream._preload_history(mock_client, limit=200)