refactor: Switch parallel handles to a HashSet

Author: tomasol

obelisk.toml

@@ -4,7 +4,7 @@ activities.directories.enabled = true   # Allow file I/O for activities with `di
 
 [log.stdout]
 enabled = true
-level = "warn,obelisk=info,app=debug" # app=trace to see replays
+level = "warn,obelisk=info,app=trace" # app=trace to see replays
 
 [[activity_wasm]]
 name = "activity_sleepy"

workflow-tutorial/src/lib.rs

@@ -4,12 +4,15 @@ use obelisk::{
     types::time::{Duration, ScheduleAt},
     workflow::workflow_support::{self, ClosingStrategy, new_join_set_generated},
 };
+use std::collections::HashSet;
 use tutorial::{
     activity::activity_sleepy::step,
     activity_obelisk_ext::activity_sleepy::{step_await_next, step_submit},
 };
 use wit_bindgen::generate;
 
+mod util;
+
 generate!({ generate_all });
 struct Component;
 export!(Component);
@@ -30,14 +33,15 @@ impl Guest for Component {
         Ok(acc)
     }
 
+    #[allow(clippy::mutable_key_type)]
     fn parallel() -> Result<u64, ()> {
         log::info("parallel started");
         let max_iterations = 10;
-        let mut handles = Vec::new();
+        let mut handles = HashSet::new();
         for i in 0..max_iterations {
             let join_set = new_join_set_generated(ClosingStrategy::Complete);
             step_submit(&join_set, i, i * 200);
-            handles.push((i, join_set));
+            handles.insert((i, join_set));
         }
         log::info("parallel submitted all child executions");
         let mut acc = 0;

workflow-tutorial/src/util.rs

@@ -0,0 +1,16 @@
+// TODO: this should be generated or moved to SDK
+use crate::obelisk::types::execution::JoinSet;
+use std::hash::Hash;
+
+impl PartialEq for JoinSet {
+    fn eq(&self, other: &Self) -> bool {
+        self.id() == other.id()
+    }
+}
+impl Eq for JoinSet {}
+
+impl Hash for JoinSet {
+    fn hash<H: std::hash::Hasher>(&self, state: &mut H) {
+        self.id().hash(state);
+    }
+}