From decb4873f1d6080f90c1fb2a8dac70423ae2d11a Mon Sep 17 00:00:00 2001
From: Ruben Fiszel <ruben@rubenfiszel.com>
Date: Wed, 11 Sep 2024 08:59:01 +0200
Subject: [PATCH] fix: same worker is transitive on nested flows

---
 backend/windmill-queue/src/jobs.rs | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/backend/windmill-queue/src/jobs.rs b/backend/windmill-queue/src/jobs.rs
index 87ca43412e..73c914c661 100644
--- a/backend/windmill-queue/src/jobs.rs
+++ b/backend/windmill-queue/src/jobs.rs
@@ -3511,6 +3511,9 @@ pub async fn push<'c, 'd, R: rsmq_async::RsmqConnection + Send + 'c>(
                 })?;
             let priority = value.priority;
             add_virtual_items_if_necessary(&mut value.modules);
+            if same_worker {
+                value.same_worker = true;
+            }
             let cache_ttl = value.cache_ttl.map(|x| x as i32).clone();
             let custom_concurrency_key = value.concurrency_key.clone();
             let concurrency_time_window_s = value.concurrency_time_window_s.clone();