summaryrefslogtreecommitdiff
path: root/shared/tests/test_broker.py
diff options
context:
space:
mode:
authorTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-01 16:24:30 +0900
committerTheSiahxyz <164138827+TheSiahxyz@users.noreply.github.com>2026-04-01 16:24:30 +0900
commit100aa624ad3f8ad466a95f9da8af30f31f77cc9c (patch)
treeef81b9f37872ed462a1f84ea238a130f758782d2 /shared/tests/test_broker.py
parent73eaf704584e5bf3c4499ccdd574af87304e1e5f (diff)
fix: resolve lint issues and final integration fixes
- Fix ambiguous variable name in binance_rest.py - Remove unused volumes variable in volume_profile_strategy.py - Fix import ordering in backtester main.py and test_metrics.py - Auto-format all files with ruff
Diffstat (limited to 'shared/tests/test_broker.py')
-rw-r--r--shared/tests/test_broker.py6
1 files changed, 5 insertions, 1 deletions
diff --git a/shared/tests/test_broker.py b/shared/tests/test_broker.py
index d3a3569..ea8b148 100644
--- a/shared/tests/test_broker.py
+++ b/shared/tests/test_broker.py
@@ -1,7 +1,8 @@
"""Tests for the Redis broker."""
+
import pytest
import json
-from unittest.mock import AsyncMock, MagicMock, patch
+from unittest.mock import AsyncMock, patch
@pytest.mark.asyncio
@@ -12,6 +13,7 @@ async def test_broker_publish():
mock_from_url.return_value = mock_redis
from shared.broker import RedisBroker
+
broker = RedisBroker("redis://localhost:6379")
data = {"type": "CANDLE", "symbol": "BTCUSDT"}
await broker.publish("candles", data)
@@ -43,6 +45,7 @@ async def test_broker_subscribe_returns_messages():
]
from shared.broker import RedisBroker
+
broker = RedisBroker("redis://localhost:6379")
messages = await broker.read("candles", last_id="$")
@@ -60,6 +63,7 @@ async def test_broker_close():
mock_from_url.return_value = mock_redis
from shared.broker import RedisBroker
+
broker = RedisBroker("redis://localhost:6379")
await broker.close()