fix: same worker is transitive on nested flows

2026-08-22 16:02:24 +00:00 · 2024-09-11 08:59:01 +02:00
parent 4720237091
commit decb4873f1
1 changed files with 3 additions and 0 deletions
@@ -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();