starred/windmill
1
0
Fork 0
mirror of https://github.com/windmill-labs/windmill.git synced 2026-09-06 00:02:13 +00:00
Code Issues Packages Projects Releases Wiki Activity

cli nits

Browse Source
This commit is contained in:
Ruben Fiszel
2023-05-06 11:11:22 +02:00
parent e585e3aea2
commit 3598a650a8
1 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files
cli/flow.ts
+7 -7
View File
@@ -49,23 +49,23 @@ export async function pushFlow(
const localFlowRaw = await Deno.readTextFile(localFlowPath + "flow.yaml");
const localFlow = yamlParse(localFlowRaw) as FlowFile;
function extractInlineScripts(modules: FlowModule[]) {
return modules.flatMap((m) => {
function replaceInlineScripts(modules: FlowModule[]) {
modules.forEach((m) => {
if (m.value.type == "rawscript") {
const path = m.value.content.split(" ")[1];
m.value.content = Deno.readTextFileSync(localFlowPath + path);
} else if (m.value.type == "forloopflow") {
extractInlineScripts(m.value.modules);
replaceInlineScripts(m.value.modules);
} else if (m.value.type == "branchall") {
m.value.branches.forEach((b) => extractInlineScripts(b.modules));
m.value.branches.forEach((b) => replaceInlineScripts(b.modules));
} else if (m.value.type == "branchone") {
m.value.branches.forEach((b) => extractInlineScripts(b.modules));
extractInlineScripts(m.value.default);
m.value.branches.forEach((b) => replaceInlineScripts(b.modules));
replaceInlineScripts(m.value.default);
}
});
}
extractInlineScripts(localFlow.value.modules);
replaceInlineScripts(localFlow.value.modules);
if (flow) {
if (isSuperset(localFlow, flow)) {