Skip to content

Commit a90d571

Browse files
committed
Added handling for dict responses
1 parent 4719d73 commit a90d571

File tree

2 files changed

+18
-6
lines changed

2 files changed

+18
-6
lines changed

tests/test_asyncio/test_search.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1545,9 +1545,15 @@ async def test_aggregations_add_scores(decoded_r: redis.Redis):
15451545

15461546
req = aggregations.AggregateRequest("*").add_scores()
15471547
res = await decoded_r.ft().aggregate(req)
1548-
assert len(res.rows) == 2
1549-
assert res.rows[0] == ["__score", "0.2"]
1550-
assert res.rows[1] == ["__score", "0.2"]
1548+
1549+
if isinstance(res, dict):
1550+
assert len(res["results"]) == 2
1551+
assert res["results"][0]["extra_attributes"] == {"__score": "0.2"}
1552+
assert res["results"][1]["extra_attributes"] == {"__score": "0.2"}
1553+
else:
1554+
assert len(res.rows) == 2
1555+
assert res.rows[0] == ["__score", "0.2"]
1556+
assert res.rows[1] == ["__score", "0.2"]
15511557

15521558

15531559
@pytest.mark.redismod

tests/test_search.py

Lines changed: 9 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -1455,9 +1455,15 @@ def test_aggregations_add_scores(client):
14551455

14561456
req = aggregations.AggregateRequest("*").add_scores()
14571457
res = client.ft().aggregate(req)
1458-
assert len(res.rows) == 2
1459-
assert res.rows[0] == ["__score", "0.2"]
1460-
assert res.rows[1] == ["__score", "0.2"]
1458+
1459+
if isinstance(res, dict):
1460+
assert len(res["results"]) == 2
1461+
assert res["results"][0]["extra_attributes"] == {"__score": "0.2"}
1462+
assert res["results"][1]["extra_attributes"] == {"__score": "0.2"}
1463+
else:
1464+
assert len(res.rows) == 2
1465+
assert res.rows[0] == ["__score", "0.2"]
1466+
assert res.rows[1] == ["__score", "0.2"]
14611467

14621468

14631469
@pytest.mark.redismod

0 commit comments

Comments
 (0)