Linter check pass

Author: mahigupta

CHANGES

@@ -1,3 +1,4 @@
+    * Fixed sentinel execute command response
     * Allow to control the minimum SSL version
     * Add an optional lock_name attribute to LockError.
     * Fix return types for `get`, `set_path` and `strappend` in JSONCommands

redis/asyncio/sentinel.py

@@ -228,15 +228,15 @@ async def execute_command(self, *args, **kwargs):
         once = bool(kwargs.get("once", False))
         if "once" in kwargs.keys():
             kwargs.pop("once")
-        
+
         # Check if command suppose to return boolean response.
         bool_resp = bool(kwargs.get("bool_resp", False))
         if "bool_resp" in kwargs.keys():
             kwargs.pop("bool_resp")
 
         if once:
             return await random.choice(self.sentinels).execute_command(*args, **kwargs)
-        
+
         tasks = [
             asyncio.Task(sentinel.execute_command(*args, **kwargs))
             for sentinel in self.sentinels
@@ -245,7 +245,7 @@ async def execute_command(self, *args, **kwargs):
 
         if bool_resp:
             return reduce(lambda x, y: x and y, responses)
-        
+
         return responses
 
     def __repr__(self):

redis/commands/sentinel.py

@@ -13,7 +13,9 @@ def sentinel(self, *args):
 
     def sentinel_get_master_addr_by_name(self, service_name):
         """Returns a (host, port) pair for the given ``service_name``"""
-        return self.execute_command("SENTINEL GET-MASTER-ADDR-BY-NAME", service_name, once=True)
+        return self.execute_command(
+            "SENTINEL GET-MASTER-ADDR-BY-NAME", service_name, once=True
+        )
 
     def sentinel_master(self, service_name):
         """Returns a dictionary containing the specified masters state."""
@@ -25,7 +27,9 @@ def sentinel_masters(self):
 
     def sentinel_monitor(self, name, ip, port, quorum):
         """Add a new master to Sentinel to be monitored"""
-        return self.execute_command("SENTINEL MONITOR", name, ip, port, quorum, bool_resp=True)
+        return self.execute_command(
+            "SENTINEL MONITOR", name, ip, port, quorum, bool_resp=True
+        )
 
     def sentinel_remove(self, name):
         """Remove a master from Sentinel's monitoring"""
@@ -52,7 +56,9 @@ def sentinel_reset(self, pattern):
         failover in progress), and removes every slave and sentinel already
         discovered and associated with the master.
         """
-        return self.execute_command("SENTINEL RESET", pattern, once=True, bool_resp=True)
+        return self.execute_command(
+            "SENTINEL RESET", pattern, once=True, bool_resp=True
+        )
 
     def sentinel_failover(self, new_master_name):
         """
@@ -61,7 +67,9 @@ def sentinel_failover(self, new_master_name):
         configuration will be published so that the other Sentinels will
         update their configurations).
         """
-        return self.execute_command("SENTINEL FAILOVER", new_master_name, bool_resp=True)
+        return self.execute_command(
+            "SENTINEL FAILOVER", new_master_name, bool_resp=True
+        )
 
     def sentinel_ckquorum(self, new_master_name):
         """
@@ -72,7 +80,9 @@ def sentinel_ckquorum(self, new_master_name):
         This command should be used in monitoring systems to check if a
         Sentinel deployment is ok.
         """
-        return self.execute_command("SENTINEL CKQUORUM", new_master_name, once=True, bool_resp=True)
+        return self.execute_command(
+            "SENTINEL CKQUORUM", new_master_name, once=True, bool_resp=True
+        )
 
     def sentinel_flushconfig(self):
         """

redis/sentinel.py

@@ -255,7 +255,7 @@ def execute_command(self, *args, **kwargs):
         once = bool(kwargs.get("once", False))
         if "once" in kwargs.keys():
             kwargs.pop("once")
-        
+
         # Check if command suppose to return boolean response.
         bool_resp = bool(kwargs.get("bool_resp", False))
         if "bool_resp" in kwargs.keys():
@@ -267,10 +267,10 @@ def execute_command(self, *args, **kwargs):
         responses = []
         for sentinel in self.sentinels:
             responses.append(sentinel.execute_command(*args, **kwargs))
-        
+
         if bool_resp:
             return reduce(lambda x, y: x and y, responses)
-        
+
         return responses
 
     def __repr__(self):