lint: clippy fixes

geofmureithi · Jul 4, 2024 · 7dc5e50 · 7dc5e50
1 parent e8c900d
commit 7dc5e50
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 3 deletions.
diff --git a/packages/apalis-core/src/layers.rs b/packages/apalis-core/src/layers.rs
@@ -182,8 +182,8 @@ impl<A: fmt::Display> AckResponse<A> {
     pub fn to_json(&self) -> String {
         format!(
             r#"{{"worker": "{}", "acknowledger": "{}", "result": "{}"}}"#,
-            self.worker.to_string(),
-            self.acknowledger.to_string(),
+            self.worker,
+            self.acknowledger,
             self.result
         )
     }

diff --git a/packages/apalis-core/src/lib.rs b/packages/apalis-core/src/lib.rs
@@ -145,7 +145,8 @@ pub mod interval {
                 Poll::Pending => return Poll::Pending,
             };
             let interval = self.interval;
-            let _ = std::mem::replace(&mut self.timer, Box::pin(sleep(interval)));
+            let fut = std::mem::replace(&mut self.timer, Box::pin(sleep(interval)));
+            drop(fut);
             Poll::Ready(Some(()))
         }
     }

diff --git a/packages/apalis-core/src/worker/buffer/worker.rs b/packages/apalis-core/src/worker/buffer/worker.rs
@@ -62,6 +62,7 @@ where
     ///
     /// If a `Message` is returned, the `bool` is true if this is the first time we received this
     /// message, and false otherwise (i.e., we tried to forward it to the backing service before).
+    #[allow(clippy::type_complexity)]
     fn poll_next_msg(
         &mut self,
         cx: &mut Context<'_>,