gihyeon/cointrader
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: AsyncClient.futures_klines await 누락 수정

Browse Source 
Made-with: Cursor
This commit is contained in:
21in7
2026-03-01 13:04:02 +09:00
parent 4940de16fc
commit 117fd9e6bc
2 changed files with 5 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
src/data_stream.py
View File

@@ -48,14 +48,10 @@ class KlineStream:
async def _preload_history(self, client: AsyncClient, limit: int = 200): async def _preload_history(self, client: AsyncClient, limit: int = 200):
"""REST API로 과거 캔들 데이터를 버퍼에 미리 채운다.""" """REST API로 과거 캔들 데이터를 버퍼에 미리 채운다."""
logger.info(f"과거 캔들 {limit}개 로드 중...") logger.info(f"과거 캔들 {limit}개 로드 중...")
loop = asyncio.get_event_loop() klines = await client.futures_klines(
klines = await loop.run_in_executor(
None,
lambda: client.futures_klines(
symbol=self.symbol.upper(), symbol=self.symbol.upper(),
interval=self.interval, interval=self.interval,
limit=limit, limit=limit,
),
) )
# 마지막 캔들은 아직 닫히지 않았을 수 있으므로 제외 # 마지막 캔들은 아직 닫히지 않았을 수 있으므로 제외
for k in klines[:-1]: for k in klines[:-1]:

2
tests/test_data_stream.py
View File

@@ -57,7 +57,7 @@ async def test_preload_history_fills_buffer():
for i in range(201) # 201개 반환 → 마지막 1개 제외 → 200개 버퍼 for i in range(201) # 201개 반환 → 마지막 1개 제외 → 200개 버퍼
] ]
mock_client = MagicMock() mock_client = AsyncMock()
mock_client.futures_klines.return_value = fake_klines mock_client.futures_klines.return_value = fake_klines
await stream._preload_history(mock_client, limit=200) await stream._preload_history(mock_client, limit=200)