@openfn/cli
Advanced tools
Comparing version
@@ -1001,2 +1001,30 @@ // src/apollo/handler.ts | ||
// src/util/override-plan-adaptors.ts | ||
function overridePlanAdaptors(plan, resolutions) { | ||
const hasRes = Object.entries(resolutions).some( | ||
([key, value]) => key !== value | ||
); | ||
if (!hasRes) | ||
return plan; | ||
return { | ||
...plan, | ||
workflow: { | ||
...plan.workflow, | ||
steps: plan.workflow.steps.map((step) => { | ||
if (isJob(step)) | ||
return { | ||
...step, | ||
adaptors: step.adaptors?.map((a) => resolutions[a] || a) | ||
}; | ||
else | ||
return step; | ||
}) | ||
} | ||
}; | ||
} | ||
function isJob(step) { | ||
return step && typeof step.expression === "string"; | ||
} | ||
var override_plan_adaptors_default = overridePlanAdaptors; | ||
// src/execute/handler.ts | ||
@@ -1031,2 +1059,3 @@ var matchStep = (plan, stepPattern, stepName, logger) => { | ||
} | ||
const moduleResolutions = {}; | ||
const { repoDir, monorepoPath, autoinstall } = options; | ||
@@ -1044,2 +1073,7 @@ if (autoinstall) { | ||
); | ||
if (autoInstallTargets.length === options.adaptors.length) { | ||
for (let i = 0; i < autoInstallTargets.length; i++) { | ||
moduleResolutions[autoInstallTargets[i]] = options.adaptors[i]; | ||
} | ||
} | ||
} | ||
@@ -1076,2 +1110,3 @@ } | ||
const state = await load_state_default(plan, options, logger, customStart); | ||
plan = override_plan_adaptors_default(plan, moduleResolutions); | ||
if (options.compile) { | ||
@@ -1078,0 +1113,0 @@ plan = await compile_default(plan, options, logger); |
{ | ||
"name": "@openfn/cli", | ||
"version": "1.10.1", | ||
"version": "1.10.2", | ||
"description": "CLI devtools for the openfn toolchain.", | ||
@@ -52,6 +52,6 @@ "engines": { | ||
"@openfn/compiler": "1.0.0", | ||
"@openfn/describe-package": "0.1.4", | ||
"@openfn/deploy": "0.8.2", | ||
"@openfn/logger": "1.0.4", | ||
"@openfn/runtime": "1.6.1", | ||
"@openfn/deploy": "0.8.2" | ||
"@openfn/describe-package": "0.1.4" | ||
}, | ||
@@ -58,0 +58,0 @@ "files": [ |
106432
0.95%3071
1.12%