From 6d24951435270eefcccd900d6965a079761bb895 Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Thu, 11 Jan 2024 20:18:48 +0100
Subject: [PATCH] fix: add cache for flow as flow step

---
 backend/windmill-worker/src/worker.rs | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/backend/windmill-worker/src/worker.rs b/backend/windmill-worker/src/worker.rs
index b0c9d31195..74ee933a09 100644
--- a/backend/windmill-worker/src/worker.rs
+++ b/backend/windmill-worker/src/worker.rs
@@ -2493,7 +2493,7 @@ async fn handle_queued_job<R: rsmq_async::RsmqConnection + Send + Sync + Clone>(
             &job.args,
         )
         .await;
-        if job.is_flow_step {
+        if job.is_flow_step && !matches!(job.job_kind, JobKind::Flow) {
             let flow_path = sqlx::query_scalar!(
                 "SELECT script_path FROM queue WHERE id = $1",
                 &job.parent_job.unwrap()