Skip to content

Commit

Permalink
Remove dynamic node from pending nodes as users might want to have th…
Browse files Browse the repository at this point in the history
…e flexibility to spawn them independently from starting the dataflow. also, dynamic nodes might create race condition when several are sequential
  • Loading branch information
haixuanTao committed Jul 29, 2024
1 parent c6f44a7 commit 26a4664
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions binaries/daemon/src/lib.rs
Original file line number Diff line number Diff line change
Expand Up @@ -647,10 +647,10 @@ impl Daemon {
}
}
if local {
dataflow.pending_nodes.insert(node.id.clone());

if node.kind.dynamic() {
dataflow.dynamic_nodes.insert(node.id.clone());
} else {
dataflow.pending_nodes.insert(node.id.clone());
}

let node_id = node.id.clone();
Expand Down

0 comments on commit 26a4664

Please sign in to comment.