diff options
| author | Avital Fine <79420960+AvitalFineRedis@users.noreply.github.com> | 2021-10-19 12:04:46 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2021-10-19 13:04:46 +0300 |
| commit | 39814846b765b1bba33cd7520b6462a9816c9d4a (patch) | |
| tree | c7a870dff97bca6854c32072ee203e049cd6fd93 /tests/test_commands.py | |
| parent | 039488d97ec545b37e903d1b791a88bac8f77973 (diff) | |
| download | redis-py-39814846b765b1bba33cd7520b6462a9816c9d4a.tar.gz | |
Add support to consumername in `xpending_range` (#1602)
Diffstat (limited to 'tests/test_commands.py')
| -rw-r--r-- | tests/test_commands.py | 8 |
1 files changed, 8 insertions, 0 deletions
diff --git a/tests/test_commands.py b/tests/test_commands.py index a7a3ce4..b7fa6bf 100644 --- a/tests/test_commands.py +++ b/tests/test_commands.py @@ -3217,6 +3217,14 @@ class TestRedisCommands: assert response[1]['message_id'] == m2 assert response[1]['consumer'] == consumer2.encode() + # test with consumer name + response = r.xpending_range(stream, group, + min='-', max='+', count=5, + consumername=consumer1) + assert len(response) == 1 + assert response[0]['message_id'] == m1 + assert response[0]['consumer'] == consumer1.encode() + @skip_if_server_version_lt('6.2.0') def test_xpending_range_idle(self, r): stream = 'stream' |