fix some breaking change in arroyo

getsentry · Sep 17, 2024 · aa1e038 · aa1e038
1 parent 28a5fbb
commit aa1e038
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/snuba/subscriptions/scheduler_consumer.py b/snuba/subscriptions/scheduler_consumer.py
@@ -210,6 +210,10 @@ def close(self, timeout: Optional[float] = None) -> None:
     def closed(self) -> bool:
         return self.__consumer.closed
 
+    @property
+    def member_id(self) -> str:
+        return self.__consumer.member_id
+
 
 class SchedulerBuilder:
     def __init__(