Bump Arroyo to 2.17.6 (#6289)

Bumped the Python requirements, not sure if anything needs to be changed on the Rust side because of https://github.com/getsentry/snuba/blob/master/rust_snuba/Cargo.toml#L34 --------- Co-authored-by: Markus Unterwaditzer <[email protected]>
getsentry · Sep 17, 2024 · 40bf550 · 40bf550
1 parent e113f91
commit 40bf550
Show file tree

Hide file tree

Showing 4 changed files with 9 additions and 5 deletions.
diff --git a/requirements.txt b/requirements.txt
@@ -26,7 +26,7 @@ pytest-watch==4.2.0
 python-dateutil==2.8.2
 python-rapidjson==1.8
 redis==4.3.4
-sentry-arroyo==2.17.1
+sentry-arroyo==2.17.6
 sentry-kafka-schemas==0.1.106
 sentry-redis-tools==0.3.0
 sentry-relay==0.8.44

diff --git a/rust_snuba/Cargo.lock b/rust_snuba/Cargo.lock
diff --git a/rust_snuba/bin/python_processor_infinite.rs b/rust_snuba/bin/python_processor_infinite.rs
@@ -20,9 +20,9 @@ fn main() {
     let output2 = output.clone();
 
     let step = RunTask::new(
-        move |_| {
+        move |message| {
             output2.fetch_add(1, Ordering::Relaxed);
-            Ok(())
+            Ok(message)
         },
         step,
     );

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__(