Fix clippy warnings

apis/rust/node/src/lib.rs

@@ -144,7 +144,6 @@ fn set_up_tracing() -> eyre::Result<()> {
         .context("failed to set tracing global subscriber")
 }
 
-#[must_use]
 pub fn manual_stop_publisher(
     communication: &mut dyn CommunicationLayer,
 ) -> eyre::Result<Box<dyn Publisher>> {

binaries/cli/src/check.rs

@@ -3,7 +3,6 @@ use dora_core::{
     adjust_shared_library_path,
     config::{InputMapping, UserInputMapping},
     descriptor::{self, source_is_url, CoreNodeKind, OperatorSource},
-    topics::ControlRequest,
 };
 use eyre::{bail, eyre, Context};
 use std::{env::consts::EXE_EXTENSION, io::Write, path::Path};

binaries/cli/src/template/cxx/mod.rs

@@ -64,7 +64,7 @@ fn create_operator(name: String, path: Option<PathBuf>) -> Result<(), eyre::ErrR
 
     // create directories
     let root = path.as_deref().unwrap_or_else(|| Path::new(&name));
-    fs::create_dir(&root)
+    fs::create_dir(root)
         .with_context(|| format!("failed to create directory `{}`", root.display()))?;
 
     let operator_path = root.join("operator.cc");
@@ -96,7 +96,7 @@ fn create_custom_node(name: String, path: Option<PathBuf>) -> Result<(), eyre::E
 
     // create directories
     let root = path.as_deref().unwrap_or_else(|| Path::new(&name));
-    fs::create_dir(&root)
+    fs::create_dir(root)
         .with_context(|| format!("failed to create directory `{}`", root.display()))?;
 
     let node_path = root.join("node.cc");

binaries/runtime/src/main.rs

@@ -1,5 +1,3 @@
-use dora_runtime;
-
 fn main() -> Result<(), eyre::Report> {
     dora_runtime::main()
 }

binaries/runtime/src/operator/python.rs

@@ -50,7 +50,7 @@ pub fn spawn(
     let path = if source_is_url(source) {
         let target_path = Path::new("build")
             .join(node_id.to_string())
-            .join(format!("{}.py", operator_id.to_string()));
+            .join(format!("{}.py", operator_id));
         // try to download the shared library
         let rt = tokio::runtime::Builder::new_current_thread()
             .enable_all()

libraries/communication-layer/request-reply/src/tcp.rs

@@ -125,7 +125,7 @@ impl TcpConnection {
     fn send(&mut self, request: &[u8]) -> std::io::Result<()> {
         let len_raw = (request.len() as u64).to_le_bytes();
         self.stream.write_all(&len_raw)?;
-        self.stream.write_all(&request)?;
+        self.stream.write_all(request)?;
         Ok(())
     }