Add types to execute method of pipelines (#3494)

Co-authored-by: Vladyslav Vildanov <[email protected]>
redis · Feb 6, 2025 · 5342409 · 5342409
1 parent d989bcc
commit 5342409
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/redis/asyncio/client.py b/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:

diff --git a/redis/client.py b/redis/client.py
@@ -1554,7 +1554,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:

diff --git a/redis/cluster.py b/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
         """