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

handle more waiting case as base case for special primitives in flows

Browse Source
This commit is contained in:
Ruben Fiszel
2022-12-06 00:05:02 +01:00
parent 31c317b358
commit c318cb255a
1 changed files with 9 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/windmill-worker/src/worker_flow.rs
+9 -3
View File
@@ -1475,7 +1475,9 @@ async fn compute_next_flow_transform<'c>(
let new_args: &mut Map<String, serde_json::Value> = &mut Map::new();
let next_loop_status = match status_module {
FlowStatusModule::WaitingForPriorSteps { .. } => {
FlowStatusModule::WaitingForPriorSteps { .. }
| FlowStatusModule::WaitingForEvents { .. }
| FlowStatusModule::WaitingForExecutor { .. } => {
let (token, by_id) = if let Some(x) = transform_context {
x
} else {
@@ -1594,7 +1596,9 @@ async fn compute_next_flow_transform<'c>(
}
FlowModuleValue::BranchOne { branches, default, .. } => {
let branch = match status_module {
FlowStatusModule::WaitingForPriorSteps { .. } => {
FlowStatusModule::WaitingForPriorSteps { .. }
| FlowStatusModule::WaitingForEvents { .. }
| FlowStatusModule::WaitingForExecutor { .. } => {
let mut branch_chosen = BranchChosen::Default;
let (token, idcontext) =
get_transform_context(db, &flow_job, previous_id, &status).await?;
@@ -1658,7 +1662,9 @@ async fn compute_next_flow_transform<'c>(
}
FlowModuleValue::BranchAll { branches, parallel, .. } => {
let (status, flow_jobs) = match status_module {
FlowStatusModule::WaitingForPriorSteps { .. } => {
FlowStatusModule::WaitingForPriorSteps { .. }
| FlowStatusModule::WaitingForEvents { .. }
| FlowStatusModule::WaitingForExecutor { .. } => {
if branches.is_empty() {
return Ok((tx, NextFlowTransform::EmptyInnerFlows));
} else if *parallel {