updated deps

Author: nassor

Cargo.lock

@@ -1,6 +1,6 @@
 [package]
 name = "cano"
-version = "0.6.0"
+version = "0.6.1"
 homepage = "https://github.com/nassor/cano"
 edition = "2024"
 description = "Simple & Fast Async Workflows in Rust - Build data processing pipelines with Tasks and Nodes"
@@ -29,7 +29,7 @@ all = ["scheduler", "tracing"]
 cargo-audit = "0.21.2"
 criterion = { version = "0.7", features = ["html_reports", "async_tokio"] }
 reqwest = { version = "0.12", features = ["json"] }
-rig-core = "0.16"
+rig-core = "0.20"
 wide = "0.7"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "fmt"] }
 chrono = { version = "0.4", features = ["serde"] }

Cargo.toml

@@ -36,7 +36,6 @@ impl Node<TestState> for DoNothingNode {
 
     async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
         // Do nothing - minimal overhead
-        ()
     }
 
     async fn post(

benches/node_performance.rs

@@ -194,7 +194,7 @@ fn is_prime(n: u64) -> bool {
         return false;
     }
     for i in 2..=(n as f64).sqrt() as u64 {
-        if n % i == 0 {
+        if n.is_multiple_of(i) {
             return false;
         }
     }

benches/workflow_performance.rs

@@ -232,8 +232,6 @@ impl Node<WorkflowState> for ReportNode {
 
         // Simulate report generation
         tokio::time::sleep(tokio::time::Duration::from_millis(100)).await;
-
-        ()
     }
 
     async fn post(

examples/mixed_workflow.rs

@@ -52,7 +52,6 @@ impl Node<MyState> for LongProcessingNode {
     async fn exec(&self, _data: Self::PrepResult) -> Self::ExecResult {
         // Simulate long-running work
         tokio::time::sleep(Duration::from_secs(5)).await;
-        ()
     }
 
     async fn post(
@@ -77,9 +76,7 @@ impl Node<MyState> for QuickNode {
         Ok(())
     }
 
-    async fn exec(&self, _data: Self::PrepResult) -> Self::ExecResult {
-        ()
-    }
+    async fn exec(&self, _data: Self::PrepResult) -> Self::ExecResult {}
 
     async fn post(
         &self,

examples/scheduler_graceful_shutdown.rs

@@ -528,10 +528,10 @@ mod tests {
 
         fn set_params(&mut self, params: DefaultParams) {
             self.params = params;
-            if let Some(multiplier_str) = self.params.get("multiplier") {
-                if let Ok(multiplier) = multiplier_str.parse::<i32>() {
-                    self.multiplier = multiplier;
-                }
+            if let Some(multiplier_str) = self.params.get("multiplier")
+                && let Ok(multiplier) = multiplier_str.parse::<i32>()
+            {
+                self.multiplier = multiplier;
             }
         }
 
@@ -570,9 +570,7 @@ mod tests {
             Ok(())
         }
 
-        async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-            ()
-        }
+        async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {}
 
         async fn post(
             &self,
@@ -927,9 +925,7 @@ mod tests {
                 }
             }
 
-            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
-            }
+            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {}
 
             async fn post(
                 &self,
@@ -975,9 +971,7 @@ mod tests {
                 Ok(())
             }
 
-            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
-            }
+            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {}
 
             async fn post(
                 &self,
@@ -1231,9 +1225,7 @@ mod tests {
                 }
             }
 
-            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
-            }
+            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {}
 
             async fn post(
                 &self,
@@ -1278,9 +1270,7 @@ mod tests {
                 Err(CanoError::preparation("Always fails"))
             }
 
-            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
-            }
+            async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {}
 
             async fn post(
                 &self,

src/node.rs

@@ -555,10 +555,10 @@ mod tests {
     impl Task<TestAction> for ParameterizedTask {
         fn set_params(&mut self, params: DefaultTaskParams) {
             self.params = params;
-            if let Some(multiplier_str) = self.params.get("multiplier") {
-                if let Ok(multiplier) = multiplier_str.parse::<i32>() {
-                    self.multiplier = multiplier;
-                }
+            if let Some(multiplier_str) = self.params.get("multiplier")
+                && let Ok(multiplier) = multiplier_str.parse::<i32>()
+            {
+                self.multiplier = multiplier;
             }
         }