Update dependencies and improve CI configuration for Rust 1.95.0

nassor · Copilot · nassor · commit 65e7b7dc7341 · 2026-04-26T22:14:15.000-04:00
Co-authored-by: Copilot &lt;copilot@github.com&gt;
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -16,62 +16,53 @@ jobs:
   test:
     name: Test
     runs-on: ubuntu-latest
-    strategy:
-      matrix:
-        rust:
-          - stable
-          - 1.89.0  # Rust minimum version
     steps:
     - uses: actions/checkout@v4
-    
+
     - name: Install Rust
       uses: dtolnay/rust-toolchain@master
       with:
-        toolchain: ${{ matrix.rust }}
-    
+        toolchain: 1.95.0
+        components: rustfmt, clippy
+
     - name: Cache cargo registry
       uses: actions/cache@v4
       with:
         path: ~/.cargo/registry
         key: ${{ runner.os }}-cargo-registry-${{ hashFiles('**/Cargo.lock') }}
-    
+
     - name: Cache cargo index
       uses: actions/cache@v4
       with:
         path: ~/.cargo/git
         key: ${{ runner.os }}-cargo-index-${{ hashFiles('**/Cargo.lock') }}
-    
+
     - name: Cache cargo build
       uses: actions/cache@v4
       with:
         path: target
         key: ${{ runner.os }}-cargo-build-target-${{ hashFiles('**/Cargo.lock') }}
-    
+
     - name: Check formatting
       run: cargo fmt --all -- --check
-      if: matrix.rust == 'stable'
-    
+
     - name: Run clippy
       run: cargo clippy --all-targets --all-features -- -D warnings
-      if: matrix.rust == 'stable'
 
     - name: Build
       run: cargo build
 
     - name: Check benchmarks
       run: cargo check --benches
-      if: matrix.rust == 'stable'
 
     - name: Check examples
       run: cargo check --examples
-      if: matrix.rust == 'stable'
-    
+
     - name: Run tests
       run: cargo test --lib
-    
+
     - name: Run doctests
       run: cargo test --doc
-      if: matrix.rust == 'stable'
 
   security_audit:
     name: Security Audit
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/Cargo.toml b/Cargo.toml
@@ -1,9 +1,9 @@
 [package]
 name = "cano"
-version = "0.8.0"
+version = "0.9.0"
 homepage = "https://nassor.github.io/cano/"
 edition = "2024"
-rust-version = "1.89.0"
+rust-version = "1.95.0"
 description = "High-performance orchestration engine for building resilient, self-healing systems in Rust. Uses Finite State Machines (FSM) for strict, type-safe transitions."
 license = "MIT"
 repository = "https://github.com/nassor/cano"
@@ -14,7 +14,7 @@ authors = ["Nassor Frazier-Silva"]
 
 [dependencies]
 async-trait = "0.1"
-tokio = { version = "1.51.1", features = ["macros", "sync", "time", "rt-multi-thread"] }
+tokio = { version = "1.52.1", features = ["macros", "sync", "time", "rt-multi-thread"] }
 rand = "0.10"
 chrono = { version = "0.4", features = ["serde"], optional = true }
 cron = { version = "0.16", optional = true }
@@ -27,16 +27,16 @@ tracing = ["dep:tracing"]
 all = ["scheduler", "tracing"]
 
 [dev-dependencies]
-axum = "0.8"
+axum = "0.8.9"
 criterion = { version = "0.8", features = ["html_reports", "async_tokio"] }
 reqwest = { version = "0.13", features = ["json"] }
-rig-core = "0.34"
+rig-core = "0.35"
 serde = { version = "1", features = ["derive"] }
 serde_json = "1"
 wide = "1.2"
 tracing-subscriber = { version = "0.3", features = ["env-filter", "fmt"] }
 chrono = { version = "0.4", features = ["serde"] }
-tokio = { version = "1.51.1", features = ["macros", "sync", "time", "rt-multi-thread", "signal"] }
+tokio = { version = "1.52.1", features = ["macros", "sync", "time", "rt-multi-thread", "signal"] }
 
 [[example]]
 name = "ai_workflow_yes_and"
diff --git a/README.md b/README.md
@@ -8,11 +8,11 @@
 [![Downloads](https://img.shields.io/crates/d/cano.svg)](https://crates.io/crates/cano)
 [![License](https://img.shields.io/crates/l/cano.svg)](https://github.com/nassor/cano/blob/main/LICENSE)
 [![CI](https://github.com/nassor/cano/workflows/CI/badge.svg)](https://github.com/nassor/cano/actions)
-[![Rust Version](https://img.shields.io/badge/rust-1.89%2B-blue.svg)](https://www.rust-lang.org)
+[![Rust Version](https://img.shields.io/badge/rust-1.95%2B-blue.svg)](https://www.rust-lang.org)
 
 <em>**Orchestrate complex async processes with finite state machines, parallel execution, and built-in scheduling.**</em>
 
-<em>Cano still far from 1.0 release. The API is subject to changes and breaking changes.</em>
+<em>Cano is still far from a 1.0 release. The API is subject to changes and may include breaking changes.</em>
 
 </div>
 
diff --git a/benches/resource_performance.rs b/benches/resource_performance.rs
@@ -75,6 +75,8 @@ fn bench_lifecycle_n_resources(c: &mut Criterion) {
                 }
                 runtime.block_on(async {
                     resources.setup_all().await.unwrap();
+                    // teardown_all returns (); per-resource errors are logged
+                    // internally. Noop never fails, so nothing to assert here.
                     resources.teardown_all().await;
                 });
             });
diff --git a/benches/task_performance.rs b/benches/task_performance.rs
@@ -725,10 +725,10 @@ fn bench_task_run_bare(c: &mut Criterion) {
             &count,
             |b, &count| {
                 let task = DirectRunTask;
+                let res = Resources::new();
 
                 b.to_async(tokio::runtime::Runtime::new().unwrap())
                     .iter(|| async {
-                        let res = Resources::new();
                         for _i in 0..count {
                             let _result = task.run(&res).await;
                         }
@@ -741,10 +741,10 @@ fn bench_task_run_bare(c: &mut Criterion) {
             &count,
             |b, &count| {
                 let task = ViaRunBareTask;
+                let res = Resources::new();
 
                 b.to_async(tokio::runtime::Runtime::new().unwrap())
                     .iter(|| async {
-                        let res = Resources::new();
                         for _i in 0..count {
                             let _result = task.run(&res).await;
                         }
diff --git a/docs/config.toml b/docs/config.toml
@@ -7,7 +7,7 @@ build_search_index = false
 generate_feeds = false
 
 [extra]
-version = "0.8.0"
+version = "0.9.0"
 github_url = "https://github.com/nassor/cano"
 crates_url = "https://crates.io/crates/cano"
 docsrs_url = "https://docs.rs/cano"
diff --git a/examples/scheduler_book_prepositions.rs b/examples/scheduler_book_prepositions.rs
@@ -278,7 +278,7 @@ impl Node<WorkflowPhase> for BookRankingNode {
         println!("🏆 Ranking books by preposition diversity...");
 
         let mut analyses = prep_res;
-        analyses.sort_by(|a, b| b.preposition_count.cmp(&a.preposition_count));
+        analyses.sort_by_key(|b| std::cmp::Reverse(b.preposition_count));
 
         analyses
             .into_iter()
diff --git a/examples/scheduler_mapreduce_books.rs b/examples/scheduler_mapreduce_books.rs
@@ -497,7 +497,7 @@ async fn reduce_global_results(global_results: &GlobalResults) -> Result<(), Can
         .collect();
 
     // Sort by preposition count
-    all_books.sort_by(|a, b| b.preposition_count.cmp(&a.preposition_count));
+    all_books.sort_by_key(|b| std::cmp::Reverse(b.preposition_count));
 
     // Display batch summaries
     println!("\n📦 Batch Summaries:");
diff --git a/examples/workflow_ad_exchange.rs b/examples/workflow_ad_exchange.rs
@@ -600,24 +600,14 @@ async fn main() -> Result<(), CanoError> {
     let result = match workflow.orchestrate(AdExchangeState::Start).await {
         Ok(state) => state,
         Err(e) => {
-            // If workflow fails due to split timeout/error, handle as NoFill
+            // If workflow fails due to split timeout/error, handle as NoFill.
+            // Reuse the original workflow/store so error tracking sees the real
+            // request and any context produced before the failure.
             eprintln!("❌ Workflow error: {}", e);
+            store.put("error_reason", e.to_string())?;
             println!("\n⚠️  Handling as No Fill due to error\n");
 
-            // Build a fresh workflow for the error recovery path
-            let store2 = MemoryStore::new();
-            store2.put(
-                "ad_request",
-                AdRequest {
-                    request_id: "req_abc123".to_string(),
-                    placement_id: "placement_728x90_top".to_string(),
-                    floor_price: 1.50,
-                },
-            )?;
-            let workflow2 = create_ad_exchange_workflow(store2);
-            workflow2
-                .orchestrate(AdExchangeState::ErrorTracking)
-                .await?
+            workflow.orchestrate(AdExchangeState::ErrorTracking).await?
         }
     };
 
diff --git a/examples/workflow_partial_results.rs b/examples/workflow_partial_results.rs
@@ -112,25 +112,22 @@ async fn main() -> Result<(), CanoError> {
         duration, result
     );
 
-    // Check individual results stored by successful tasks
-    let result_1 = store.get::<String>("result_1").ok();
-    let result_2 = store.get::<String>("result_2").ok();
+    // Check results stored by every spawned task — order of completion is not guaranteed,
+    // so iterate over all task IDs rather than hardcoding the expected pair.
+    let task_ids = [1usize, 2, 3, 4];
+    let results: Vec<(usize, Option<String>)> = task_ids
+        .iter()
+        .map(|&id| (id, store.get::<String>(&format!("result_{id}")).ok()))
+        .collect();
 
     println!("\nResults:");
-    println!("- Task 1: {:?}", result_1);
-    println!("- Task 2: {:?}", result_2);
-
-    // Verify results
-    // We expect Task 1 (success) and Task 2 (success) to complete.
-    // Task 3 (failure) will complete but not count towards the threshold.
-    // Task 4 should be cancelled because we only asked for 2 successful completions.
-    // Task 1 succeeds at 100ms.
-    // Task 3 fails at 150ms.
-    // Task 2 succeeds at 500ms.
-    // So at 500ms we have 2 successes.
-    // The workflow should proceed.
-
-    let successes = [result_1, result_2].iter().filter(|r| r.is_some()).count();
+    for (id, value) in &results {
+        println!("- Task {}: {:?}", id, value);
+    }
+
+    // PartialResults(2) waits for 2 successful completions (failures don't count).
+    // Task 3 fails so never stores; whichever 2 successes finish first satisfy the join.
+    let successes = results.iter().filter(|(_, r)| r.is_some()).count();
     if successes >= 2 {
         println!("\nSUCCESS: Workflow behaved as expected (waited for successes).");
     } else {
diff --git a/src/workflow.rs b/src/workflow.rs
@@ -813,15 +813,13 @@ where
 
                     // Check if we can return early based on strategy
                     match &join_config.strategy {
-                        JoinStrategy::Any => {
-                            if !split_result.successes.is_empty() {
-                                break;
-                            }
+                        JoinStrategy::Any if !split_result.successes.is_empty() => {
+                            break;
                         }
-                        JoinStrategy::PartialResults(min) => {
-                            if split_result.successes.len() >= *min {
-                                break;
-                            }
+                        JoinStrategy::PartialResults(min)
+                            if split_result.successes.len() >= *min =>
+                        {
+                            break;
                         }
                         _ => {} // Continue for other strategies
                     }
@@ -1621,8 +1619,7 @@ mod tests {
 
     #[tokio::test]
     async fn test_unregistered_state_error() {
-        let workflow =
-            Workflow::<TestState>::bare().add_exit_state(TestState::Complete);
+        let workflow = Workflow::<TestState>::bare().add_exit_state(TestState::Complete);
 
         let result = workflow.orchestrate(TestState::Start).await;
         assert!(result.is_err());
@@ -1651,8 +1648,8 @@ mod tests {
 
     #[test]
     fn test_validate_no_exit_states() {
-        let workflow = Workflow::bare()
-            .register(TestState::Start, SimpleTask::new(TestState::Complete));
+        let workflow =
+            Workflow::bare().register(TestState::Start, SimpleTask::new(TestState::Complete));
         let result = workflow.validate();
         assert!(result.is_err());
         assert!(
@@ -1819,8 +1816,8 @@ mod tests {
 
     #[tokio::test]
     async fn test_workflow_no_exit_states() {
-        let workflow = Workflow::bare()
-            .register(TestState::Start, SimpleTask::new(TestState::Complete));
+        let workflow =
+            Workflow::bare().register(TestState::Start, SimpleTask::new(TestState::Complete));
         let result = workflow.orchestrate(TestState::Start).await;
         assert!(result.is_err());
         assert!(

Original file line number	Diff line number	Diff line change
`@@ -75,6 +75,8 @@ fn bench_lifecycle_n_resources(c: &mut Criterion) {`
`75`	`75`	`}`
`76`	`76`	`runtime.block_on(async {`
`77`	`77`	`resources.setup_all().await.unwrap();`
	`78`	`+ // teardown_all returns (); per-resource errors are logged`
	`79`	`+ // internally. Noop never fails, so nothing to assert here.`
`78`	`80`	`resources.teardown_all().await;`
`79`	`81`	`});`
`80`	`82`	`});`