Skip to content

Commit 6accc3e

Browse files
committed
debug all upstreams done
1 parent 434e8bc commit 6accc3e

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

src/engine.rs

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1653,10 +1653,16 @@ impl<T: PPGEvaluatorStrategy> PPGEvaluator<T> {
16531653
fn all_upstreams_done(dag: &GraphType, jobs: &mut [NodeInfo], node_idx: NodeIndex) -> bool {
16541654
//there's no point caching this - it never get's called again if it ever returned true
16551655
let upstreams = dag.neighbors_directed(node_idx, Direction::Incoming);
1656+
info!(
1657+
"all_upstreams_done for node_idx:{}",
1658+
node_idx
1659+
);
1660+
16561661
for upstream_idx in upstreams {
16571662
if !jobs[upstream_idx as usize].state.is_finished() {
16581663
return false;
16591664
}
1665+
info!("upstream index {} is done", upstream_idx);
16601666
}
16611667
true
16621668
}

0 commit comments

Comments
 (0)