feat: add workspace variable to worker tag

2026-08-19 00:02:03 +00:00 · 2023-08-31 11:00:45 +02:00
parent bb749c14f8
commit 276cd6dac3
1 changed files with 7 additions and 6 deletions
@@ -1654,12 +1654,13 @@ pub async fn push<'c, R: rsmq_async::RsmqConnection + Send + 'c>(
                "deno".to_string()
            }
        };
-        tag.unwrap_or_else(|| {
-            language
-                .as_ref()
-                .map(|x| x.as_str().replace("$workspace", workspace_id))
-                .unwrap_or_else(default)
-        })
+        tag.map(|x| x.as_str().replace("$workspace", workspace_id).to_string())
+            .unwrap_or_else(|| {
+                language
+                    .as_ref()
+                    .map(|x| x.as_str().to_string())
+                    .unwrap_or_else(default)
+            })
    };

    let mut tx = match tx {