From 4fb4c4d62f5d349d06a0e9722ac64c1a17b4d4a0 Mon Sep 17 00:00:00 2001 From: Riya Chakraborty Date: Wed, 11 Sep 2024 10:50:20 -0700 Subject: [PATCH 1/5] bump --- requirements.txt | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/requirements.txt b/requirements.txt index 3723e817ee..e583108f36 100644 --- 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.5 sentry-kafka-schemas==0.1.106 sentry-redis-tools==0.3.0 sentry-relay==0.8.44 From 35f194d8e32aab2850eb6b2e0d6820b1c5a44d13 Mon Sep 17 00:00:00 2001 From: Riya Chakraborty Date: Wed, 11 Sep 2024 10:56:45 -0700 Subject: [PATCH 2/5] cargo update --- rust_snuba/Cargo.lock | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rust_snuba/Cargo.lock b/rust_snuba/Cargo.lock index 620e3027cb..c0fc348043 100644 --- a/rust_snuba/Cargo.lock +++ b/rust_snuba/Cargo.lock @@ -2852,8 +2852,8 @@ dependencies = [ [[package]] name = "rust_arroyo" -version = "2.17.4" -source = "git+https://github.com/getsentry/arroyo#b15d5467a4958b18ba50175e468e4b70535cb669" +version = "2.17.5" +source = "git+https://github.com/getsentry/arroyo#60cb7a4890bdf3b7f2cba77628346a771e66b9b3" dependencies = [ "chrono", "coarsetime", From faf978bc71893b8aad680df45ebba6be9a782744 Mon Sep 17 00:00:00 2001 From: Riya Chakraborty Date: Wed, 11 Sep 2024 14:11:22 -0700 Subject: [PATCH 3/5] try again --- requirements.txt | 2 +- rust_snuba/Cargo.lock | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/requirements.txt b/requirements.txt index e583108f36..cf8ecebd7e 100644 --- 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.5 +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 index c0fc348043..b0b0025916 100644 --- a/rust_snuba/Cargo.lock +++ b/rust_snuba/Cargo.lock @@ -2852,8 +2852,8 @@ dependencies = [ [[package]] name = "rust_arroyo" -version = "2.17.5" -source = "git+https://github.com/getsentry/arroyo#60cb7a4890bdf3b7f2cba77628346a771e66b9b3" +version = "2.17.6" +source = "git+https://github.com/getsentry/arroyo#084c60732a11006a70e6ae56f0ae1cdf8a6dd7d8" dependencies = [ "chrono", "coarsetime", From dd317b88ecdb9f087bd05bebe534c19b9aa348a1 Mon Sep 17 00:00:00 2001 From: Markus Unterwaditzer Date: Thu, 12 Sep 2024 20:48:13 +0200 Subject: [PATCH 4/5] fix example --- rust_snuba/bin/python_processor_infinite.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/rust_snuba/bin/python_processor_infinite.rs b/rust_snuba/bin/python_processor_infinite.rs index 8aaf285836..19f1cf7908 100644 --- 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, ); From aa1e0384f53189e17e1619594f8fda98a66786c2 Mon Sep 17 00:00:00 2001 From: Markus Unterwaditzer Date: Tue, 17 Sep 2024 17:57:03 +0200 Subject: [PATCH 5/5] fix some breaking change in arroyo --- snuba/subscriptions/scheduler_consumer.py | 4 ++++ 1 file changed, 4 insertions(+) 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__(