@openfn/cli
Advanced tools
Comparing version
@@ -34,25 +34,4 @@ // src/execute/execute.ts | ||
// src/util/abort.ts | ||
var AbortError = class extends Error { | ||
constructor(reason) { | ||
super(reason); | ||
} | ||
handled = true; | ||
}; | ||
var abort_default = (logger, reason, error, help) => { | ||
const e = new AbortError(reason); | ||
logger.error(reason); | ||
if (error) { | ||
logger.error(error.message); | ||
} | ||
if (help) { | ||
logger.always(help); | ||
} | ||
logger.break(); | ||
logger.error("Critical error: aborting command"); | ||
throw e; | ||
}; | ||
// src/execute/execute.ts | ||
var execute_default = async (input, state, opts, logger) => { | ||
var execute_default = async (input, state, opts) => { | ||
try { | ||
@@ -73,3 +52,4 @@ const result = await run(input, state, { | ||
} catch (e) { | ||
abort_default(logger, "Invalid workflow", e); | ||
e.handled = true; | ||
throw e; | ||
} | ||
@@ -234,2 +214,25 @@ }; | ||
import { getModulePath } from "@openfn/runtime"; | ||
// src/util/abort.ts | ||
var AbortError = class extends Error { | ||
constructor(reason) { | ||
super(reason); | ||
} | ||
handled = true; | ||
}; | ||
var abort_default = (logger, reason, error, help) => { | ||
const e = new AbortError(reason); | ||
logger.error(reason); | ||
if (error) { | ||
logger.error(error.message); | ||
} | ||
if (help) { | ||
logger.always(help); | ||
} | ||
logger.break(); | ||
logger.error("Critical error: aborting command"); | ||
throw e; | ||
}; | ||
// src/compile/compile.ts | ||
var compile_default = async (opts, log) => { | ||
@@ -638,3 +641,3 @@ log.debug("Compiling..."); | ||
try { | ||
const result = await execute_default(input, state, options, logger); | ||
const result = await execute_default(input, state, options); | ||
await serialize_output_default(options, result, logger); | ||
@@ -727,11 +730,5 @@ const duration = printDuration((/* @__PURE__ */ new Date()).getTime() - start); | ||
} | ||
const silentLogger = createNullLogger(); | ||
const state = await load_state_default(opts, silentLogger); | ||
const state = await load_state_default(opts, createNullLogger()); | ||
const code = await compile_default(opts, logger); | ||
const result = await execute_default( | ||
code, | ||
state, | ||
opts, | ||
silentLogger | ||
); | ||
const result = await execute_default(code, state, opts); | ||
logger.success(`Result: ${result.data.answer}`); | ||
@@ -738,0 +735,0 @@ return result; |
{ | ||
"name": "@openfn/cli", | ||
"version": "0.4.3", | ||
"version": "0.4.4", | ||
"description": "CLI devtools for the openfn toolchain.", | ||
@@ -47,7 +47,7 @@ "engines": { | ||
"yargs": "^17.7.2", | ||
"@openfn/compiler": "0.0.38", | ||
"@openfn/deploy": "0.2.9", | ||
"@openfn/describe-package": "0.0.18", | ||
"@openfn/compiler": "0.0.38", | ||
"@openfn/logger": "0.0.19", | ||
"@openfn/runtime": "0.0.33" | ||
"@openfn/runtime": "0.1.0" | ||
}, | ||
@@ -54,0 +54,0 @@ "files": [ |
3
50%71804
-0.11%1981
-0.2%+ Added
- Removed
Updated