fix (#1544): correct Redis message nack & reject signature

airtai · Jun 21, 2024 · f93bb25 · f93bb25
1 parent f8bb6bc
commit f93bb25
Showing 1 changed file with 16 additions and 0 deletions.
diff --git a/faststream/redis/message.py b/faststream/redis/message.py
@@ -130,6 +130,22 @@ async def ack(
             await redis.xack(channel, group, *ids)  # type: ignore[no-untyped-call]
             await super().ack()
 
+    @override
+    async def nack(
+        self,
+        redis: Optional["Redis[bytes]"] = None,
+        group: Optional[str] = None,
+    ) -> None:
+        await super().nack()
+
+    @override
+    async def reject(
+        self,
+        redis: Optional["Redis[bytes]"] = None,
+        group: Optional[str] = None,
+    ) -> None:
+        await super().reject()
+
 
 class RedisStreamMessage(_RedisStreamMessageMixin[DefaultStreamMessage]):
     pass