fix tests and examples

getsentry · May 17, 2024 · f06f61e · f06f61e
1 parent dfe3eb4
commit f06f61e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 3 deletions.
diff --git a/rust-arroyo/examples/base_processor.rs b/rust-arroyo/examples/base_processor.rs
@@ -1,6 +1,7 @@
 extern crate rust_arroyo;
 
-use chrono::Duration;
+use std::time::Duration;
+
 use rust_arroyo::backends::kafka::config::KafkaConfig;
 use rust_arroyo::backends::kafka::types::KafkaPayload;
 use rust_arroyo::backends::kafka::InitialOffset;
@@ -12,7 +13,7 @@ use rust_arroyo::types::Topic;
 struct TestFactory {}
 impl ProcessingStrategyFactory<KafkaPayload> for TestFactory {
     fn create(&self) -> Box<dyn ProcessingStrategy<KafkaPayload>> {
-        Box::new(CommitOffsets::new(Duration::seconds(1)))
+        Box::new(CommitOffsets::new(Duration::from_secs(1)))
     }
 }
 

diff --git a/rust-arroyo/src/processing/strategies/commit_offsets.rs b/rust-arroyo/src/processing/strategies/commit_offsets.rs
@@ -119,7 +119,7 @@ mod tests {
             }),
         };
 
-        let mut noop = CommitOffsets::new(chrono::Duration::seconds(1));
+        let mut noop = CommitOffsets::new(Duration::from_secs(1));
 
         let mut commit_req1 = CommitRequest {
             positions: Default::default(),