Merge branch 'master' into typing_for_client_init

Author: vladvildanov

doctests/dt_list.py

@@ -165,20 +165,20 @@
 # REMOVE_END
 
 # STEP_START ltrim
-res27 = r.lpush("bikes:repairs", "bike:1", "bike:2", "bike:3", "bike:4", "bike:5")
+res27 = r.rpush("bikes:repairs", "bike:1", "bike:2", "bike:3", "bike:4", "bike:5")
 print(res27)  # >>> 5
 
 res28 = r.ltrim("bikes:repairs", 0, 2)
 print(res28)  # >>> True
 
 res29 = r.lrange("bikes:repairs", 0, -1)
-print(res29)  # >>> ['bike:5', 'bike:4', 'bike:3']
+print(res29)  # >>> ['bike:1', 'bike:2', 'bike:3']
 # STEP_END
 
 # REMOVE_START
 assert res27 == 5
 assert res28 is True
-assert res29 == ["bike:5", "bike:4", "bike:3"]
+assert res29 == ["bike:1", "bike:2", "bike:3"]
 r.delete("bikes:repairs")
 # REMOVE_END
 

redis/asyncio/client.py

@@ -1554,7 +1554,7 @@ async def _disconnect_raise_reset(self, conn: Connection, error: Exception):
             await self.reset()
             raise
 
-    async def execute(self, raise_on_error: bool = True):
+    async def execute(self, raise_on_error: bool = True) -> List[Any]:
         """Execute all the commands in the current pipeline"""
         stack = self.command_stack
         if not stack and not self.watching:

redis/client.py

@@ -1569,7 +1569,7 @@ def _disconnect_raise_reset(
             self.reset()
             raise error
 
-    def execute(self, raise_on_error=True):
+    def execute(self, raise_on_error: bool = True) -> List[Any]:
         """Execute all the commands in the current pipeline"""
         stack = self.command_stack
         if not stack and not self.watching:

redis/cluster.py

@@ -2050,7 +2050,7 @@ def annotate_exception(self, exception, number, command):
         )
         exception.args = (msg,) + exception.args[1:]
 
-    def execute(self, raise_on_error=True):
+    def execute(self, raise_on_error: bool = True) -> List[Any]:
         """
         Execute all the commands in the current pipeline
         """