fix: add group/consumer to hash to avoid overwriting

airtai · May 23, 2024 · 16494a9 · 16494a9
1 parent 6c667ff
commit 16494a9
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}")