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,11 +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>() {
+            if let Some(multiplier_str) = self.params.get("multiplier")
+                && let Ok(multiplier) = multiplier_str.parse::<i32>() {
                     self.multiplier = multiplier;
                 }
-            }
         }
 
         async fn prep(&self, _store: &MemoryStore) -> Result<Self::PrepResult, CanoError> {
@@ -571,7 +570,6 @@ mod tests {
         }
 
         async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-            ()
         }
 
         async fn post(
@@ -928,7 +926,6 @@ mod tests {
             }
 
             async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
             }
 
             async fn post(
@@ -976,7 +973,6 @@ mod tests {
             }
 
             async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
             }
 
             async fn post(
@@ -1232,7 +1228,6 @@ mod tests {
             }
 
             async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
             }
 
             async fn post(
@@ -1279,7 +1274,6 @@ mod tests {
             }
 
             async fn exec(&self, _prep_res: Self::PrepResult) -> Self::ExecResult {
-                ()
             }
 
             async fn post(

src/node.rs

@@ -555,11 +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>() {
+            if let Some(multiplier_str) = self.params.get("multiplier")
+                && let Ok(multiplier) = multiplier_str.parse::<i32>() {
                     self.multiplier = multiplier;
                 }
-            }
         }
 
         async fn run(&self, store: &MemoryStore) -> Result<TestAction, CanoError> {