wrap xgroup_create's MKSTREAM option in a Token.get_token()

andymccurdy · andymccurdy · commit 320afd36c0fd · 2018-11-05T15:05:43.000-08:00
diff --git a/redis/client.py b/redis/client.py
@@ -1879,7 +1879,7 @@ def xgroup_create(self, name, groupname, id='$', mkstream=False):
         """
         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):
