diff options
| author | Andy McCurdy <andy@andymccurdy.com> | 2018-11-05 15:05:43 -0800 |
|---|---|---|
| committer | Andy McCurdy <andy@andymccurdy.com> | 2018-11-05 15:05:43 -0800 |
| commit | 320afd36c0fd844a63cbff1a3ed3f38085493783 (patch) | |
| tree | d8b27bc24db3a4c19eeccbcc075eef4e7ae46443 | |
| parent | 5f61ad9135b649225d4a944211e96e297d56f585 (diff) | |
| download | redis-py-320afd36c0fd844a63cbff1a3ed3f38085493783.tar.gz | |
wrap xgroup_create's MKSTREAM option in a Token.get_token()
| -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): |