diff --git a/snuba/subscriptions/scheduler_consumer.py b/snuba/subscriptions/scheduler_consumer.py index 794b3fe6c6..cda3021cbe 100644 --- 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__(