chore(deps): Bump sentry_arroyo to 2.40.0

sentry_streams/Cargo.toml

@@ -6,7 +6,7 @@ edition = "2021"
 [dependencies]
 pyo3 = { version = "0.28.3" }
 serde = { version = "1.0", features = ["derive"] }
-sentry_arroyo = { version = "2.39.2", features = ["ssl"] }
+sentry_arroyo = { version = "2.40.0", features = ["ssl"] }
 chrono = "0.4.40"
 tracing = "0.1.40"
 tracing-subscriber = "0.3.20"

sentry_streams/src/fake_strategy.rs

@@ -4,8 +4,8 @@ use crate::routes::RoutedValue;
 use crate::utils::traced_with_gil;
 
 use sentry_arroyo::processing::strategies::{
-    merge_commit_request, CommitRequest, InvalidMessage, MessageRejected, ProcessingStrategy,
-    StrategyError, SubmitError,
+    merge_commit_request, CommitRequest, InvalidMessage, InvalidMessageReason, MessageRejected,
+    ProcessingStrategy, StrategyError, SubmitError,
 };
 use sentry_arroyo::types::{AnyMessage, BrokerMessage, InnerMessage, Message, Partition, Topic};
 use std::collections::HashMap;
@@ -61,6 +61,7 @@ impl ProcessingStrategy<RoutedValue> for FakeStrategy {
                             topic: Topic::new("test"),
                             index: 0,
                         },
+                        reason: InvalidMessageReason::Invalid,
                     }))
                 }
             }

sentry_streams/src/filter_step.rs

@@ -216,8 +216,9 @@ mod tests {
                 10,
                 Utc::now(),
             );
-            let SubmitError::InvalidMessage(InvalidMessage { partition, offset }) =
-                filter.submit(message).unwrap_err()
+            let SubmitError::InvalidMessage(InvalidMessage {
+                partition, offset, ..
+            }) = filter.submit(message).unwrap_err()
             else {
                 panic!("Expected SubmitError::InvalidMessage")
             };

sentry_streams/src/header_filter_step.rs

@@ -333,8 +333,9 @@ mod tests {
                 10,
                 Utc::now(),
             );
-            let SubmitError::InvalidMessage(InvalidMessage { partition, offset }) =
-                strategy.submit(message).unwrap_err()
+            let SubmitError::InvalidMessage(InvalidMessage {
+                partition, offset, ..
+            }) = strategy.submit(message).unwrap_err()
             else {
                 panic!("Expected SubmitError::InvalidMessage")
             };

sentry_streams/src/python_operator.rs

@@ -9,9 +9,9 @@ use crate::utils::traced_with_gil;
 use pyo3::types::{PyDict, PyTuple};
 use pyo3::Python;
 use pyo3::{import_exception, prelude::*};
-use sentry_arroyo::processing::strategies::ProcessingStrategy;
 use sentry_arroyo::processing::strategies::SubmitError;
 use sentry_arroyo::processing::strategies::{merge_commit_request, CommitRequest, StrategyError};
+use sentry_arroyo::processing::strategies::{InvalidMessageReason, ProcessingStrategy};
 use sentry_arroyo::types::{Message, Partition, Topic};
 use sentry_arroyo::utils::timing::Deadline;
 use std::collections::VecDeque;
@@ -248,6 +248,7 @@ impl ProcessingStrategy<RoutedValue> for PythonAdapter {
                         offset,
                         partition: convert_partition(partition)
                             .expect("Unable to convert partition from InvalidMessage into sentry_arroyo::types::Partition"),
+                        reason: InvalidMessageReason::Invalid,
                     },
                 ))
             } else {
@@ -540,7 +541,8 @@ class RustOperatorDelegateFactory:
                 Err(SubmitError::InvalidMessage(
                     sentry_arroyo::processing::strategies::InvalidMessage {
                         partition: Partition { .. },
-                        offset: 42
+                        offset: 42,
+                        ..
                     }
                 ))
             ));
@@ -648,7 +650,8 @@ class RustOperatorDelegateFactory:
                 Err(StrategyError::InvalidMessage(
                     sentry_arroyo::processing::strategies::InvalidMessage {
                         partition: Partition { .. },
-                        offset: 0
+                        offset: 0,
+                        ..
                     }
                 ))
             ));

sentry_streams/src/routers.rs

@@ -167,8 +167,9 @@ mod tests {
                 10,
                 Utc::now(),
             );
-            let SubmitError::InvalidMessage(InvalidMessage { partition, offset }) =
-                router.submit(message).unwrap_err()
+            let SubmitError::InvalidMessage(InvalidMessage {
+                partition, offset, ..
+            }) = router.submit(message).unwrap_err()
             else {
                 panic!("Expected SubmitError::InvalidMessage")
             };

sentry_streams/src/transformer.rs

@@ -183,8 +183,9 @@ mod tests {
                 10,
                 Utc::now(),
             );
-            let SubmitError::InvalidMessage(InvalidMessage { partition, offset }) =
-                transform.submit(message).unwrap_err()
+            let SubmitError::InvalidMessage(InvalidMessage {
+                partition, offset, ..
+            }) = transform.submit(message).unwrap_err()
             else {
                 panic!("Expected SubmitError::InvalidMessage")
             };