From 51ce2f8cb308da285dab0dc433bf596caa5eeed0 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Tue, 21 Nov 2023 13:51:55 +0100
Subject: [PATCH] fix: fix embedded approval step timeouts

---
 backend/windmill-worker/src/worker_flow.rs | 23 ++++++++++++++++++++--
 1 file changed, 21 insertions(+), 2 deletions(-)

diff --git a/backend/windmill-worker/src/worker_flow.rs b/backend/windmill-worker/src/worker_flow.rs
index a4ea2d0249..1cca5aa0d2 100644
--- a/backend/windmill-worker/src/worker_flow.rs
+++ b/backend/windmill-worker/src/worker_flow.rs
@@ -1383,10 +1383,29 @@ async fn push_next_flow_job<R: rsmq_async::RsmqConnection + Send + Sync + Clone>
                     logs,
                     0,
                     canceled_by,
-                    rsmq,
+                    rsmq.clone(),
                 )
                 .await?;
-
+                if flow_job.is_flow_step {
+                    if let Some(parent_job) = flow_job.parent_job {
+                        update_flow_status_after_job_completion(
+                            db,
+                            client,
+                            parent_job,
+                            &flow_job.id,
+                            &flow_job.workspace_id,
+                            true,
+                            &to_raw_value(&result),
+                            false,
+                            same_worker_tx.clone(),
+                            &worker_dir,
+                            None,
+                            rsmq,
+                            worker_name,
+                        )
+                        .await?;
+                    }
+                }
                 return Ok(());
             }
         }