fix: add group/consumer to hash to avoid overwriting (#1463)

Co-authored-by: zumuta <[email protected]> Co-authored-by: Kumaran Rajendhiran <[email protected]>
airtai · May 24, 2024 · f3bc25c · f3bc25c
1 parent 44de4c9
commit f3bc25c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/faststream/redis/schemas/stream_sub.py b/faststream/redis/schemas/stream_sub.py
@@ -57,4 +57,8 @@ def __init__(
         self.max_records = max_records
 
     def __hash__(self) -> int:
+        if self.group is not None:
+            return hash(
+                f"stream:{self.name} group:{self.group} consumer:{self.consumer}"
+            )
         return hash(f"stream:{self.name}")