Fixes #1116

redis · Jan 27, 2019 · aaf6e6b · aaf6e6b
1 parent bfa2e77
commit aaf6e6b
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/CHANGES b/CHANGES
@@ -1,4 +1,7 @@
 * 3.1.0 (in development)
+    * Fixed XREADGROUP to return an empty dictionary for messages that
+      have been deleted but still exist in the unacknowledged queue. Thanks
+      @xeizmendi. #1116
     * Added an owned method to Lock objects. owned returns a boolean
       indicating whether the current lock instance still owns the lock.
       Thanks Dave Johansen. #1112

diff --git a/tests/test_commands.py b/tests/test_commands.py
@@ -2213,7 +2213,7 @@ def test_xreadgroup(self, r):
         # now there should be nothing pending
         assert len(r.xreadgroup(group, consumer,
                                 streams={stream: '0'})[0][1]) == 0
-        
+
         r.xgroup_destroy(stream, group)
         r.xgroup_create(stream, group, '0')
         # delete all the messages in the stream