diff options
| -rwxr-xr-x | redis/client.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/redis/client.py b/redis/client.py index 13aa689..737ae60 100755 --- a/redis/client.py +++ b/redis/client.py @@ -1879,7 +1879,7 @@ class StrictRedis(object): """ pieces = ['XGROUP CREATE', name, groupname, id] if mkstream: - pieces.append('MKSTREAM') + pieces.append(Token.get_token('MKSTREAM')) return self.execute_command(*pieces) def xgroup_delconsumer(self, name, groupname, consumername): |