1
1
from unittest import mock
2
- from asyncio import Future
3
2
4
3
import pytest
5
4
from redis import asyncio as aioredis
@@ -11,7 +10,7 @@ class TestRedisClient:
11
10
12
11
@pytest.fixture
13
12
def async_mock(self):
14
- yield mock.MagicMock(return_value=Future() )
13
+ yield mock.AsyncMock( )
15
14
16
15
def test_should_create_client_and_populate_defaults(self):
17
16
# given / when
@@ -58,7 +57,7 @@ class TestRedisClient:
58
57
# given
59
58
RedisClient.open_redis_client()
60
59
RedisClient.redis_client.ping = async_mock
61
- async_mock.return_value.set_result( True)
60
+ async_mock.return_value = True
62
61
63
62
# when
64
63
result = await RedisClient.ping()
@@ -85,7 +84,7 @@ class TestRedisClient:
85
84
# given
86
85
RedisClient.open_redis_client()
87
86
RedisClient.redis_client.set = async_mock
88
- async_mock.return_value.set_result( "OK")
87
+ async_mock.return_value = "OK"
89
88
90
89
# when
91
90
result = await RedisClient.set("key", "value")
@@ -110,7 +109,7 @@ class TestRedisClient:
110
109
# given
111
110
RedisClient.open_redis_client()
112
111
RedisClient.redis_client.rpush = async_mock
113
- async_mock.return_value.set_result(10)
112
+ async_mock.return_value = 10
114
113
115
114
# when
116
115
result = await RedisClient.rpush("key", "value")
@@ -135,7 +134,7 @@ class TestRedisClient:
135
134
# given
136
135
RedisClient.open_redis_client()
137
136
RedisClient.redis_client.exists = async_mock
138
- async_mock.return_value.set_result( True)
137
+ async_mock.return_value = True
139
138
140
139
# when
141
140
result = await RedisClient.exists("key")
@@ -160,7 +159,7 @@ class TestRedisClient:
160
159
# given
161
160
RedisClient.open_redis_client()
162
161
RedisClient.redis_client.get = async_mock
163
- async_mock.return_value.set_result( "value")
162
+ async_mock.return_value = "value"
164
163
165
164
# when
166
165
result = await RedisClient.get("key")
@@ -185,7 +184,7 @@ class TestRedisClient:
185
184
# given
186
185
RedisClient.open_redis_client()
187
186
RedisClient.redis_client.lrange = async_mock
188
- async_mock.return_value.set_result( ["value", "value2"])
187
+ async_mock.return_value = ["value", "value2"]
189
188
190
189
# when
191
190
result = await RedisClient.lrange("key", 1, -1)
0 commit comments