From b3e821e1b2cda9a5e4e0a1ed083bafd478bd37d5 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Fri, 29 Jul 2022 20:48:39 +0200
Subject: [PATCH] also handle the case where it's the input transform of the
 first flow job that fails

---
 backend/src/worker.rs | 24 ++++++++++++++++--------
 1 file changed, 16 insertions(+), 8 deletions(-)

diff --git a/backend/src/worker.rs b/backend/src/worker.rs
index dc16c7dbd6..e32f76c9bf 100644
--- a/backend/src/worker.rs
+++ b/backend/src/worker.rs
@@ -133,14 +133,22 @@ pub async fn run_worker(
                     )
                     .await;
 
-                    let _ = postprocess_queued_job(
-                        job2.schedule_path,
-                        job2.script_path,
-                        &job2.workspace_id,
-                        job2.id,
-                        db,
-                    )
-                    .await;
+                    {
+                        let job = job2.clone();
+                        let _ = postprocess_queued_job(
+                            job.schedule_path,
+                            job.script_path,
+                            &job2.workspace_id,
+                            job2.id,
+                            db,
+                        )
+                        .await;
+                    }
+
+                    if job2.parent_job.is_some() {
+                        let _ =
+                            update_flow_status_after_job_completion(db, &job2, false, None).await;
+                    }
                     tracing::error!(job_id = %job2.id, "Error handling job: {err_string}");
                 };
             }