starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-08 00:03:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

deactive forloop pruning in-presence of sleep or suspend

Browse Source
This commit is contained in:
Ruben Fiszel
2023-11-02 08:32:45 +01:00
parent 6251c46b6b
commit d3a4072488
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker_flow.rs
+5 -2
View File
@@ -2107,8 +2107,11 @@ async fn compute_next_flow_transform(
/* forloop modules are expected set `iter: { value: Value, index: usize }` as job arguments */
FlowModuleValue::ForloopFlow { modules, iterator, parallel, .. } => {
// if it's a simple single step flow, we will collapse it as an optimization and need to pass flow_input as an arg
let is_simple =
modules.len() == 1 && modules[0].value.is_simple() && flow.failure_module.is_none();
let is_simple = modules.len() == 1
&& modules[0].value.is_simple()
&& modules[0].sleep.is_none()
&& modules[0].suspend.is_none()
&& flow.failure_module.is_none();
let next_loop_status = match status_module {
FlowStatusModule::WaitingForPriorSteps { .. }