diff options
author | Elizabeth <me@liz.coffee> | 2025-06-02 16:52:52 -0700 |
---|---|---|
committer | Elizabeth <me@liz.coffee> | 2025-06-02 16:52:52 -0700 |
commit | 98f5c21aa65bbbca01a186a754249335b4afef57 (patch) | |
tree | 0fc8e01a73f0a3be4534c11724ad2ff634b4fd2f /worker/executor.ts | |
parent | 373d9ec700c0097a22cf665a8e33cf48998d1dc2 (diff) | |
download | ci-98f5c21aa65bbbca01a186a754249335b4afef57.tar.gz ci-98f5c21aa65bbbca01a186a754249335b4afef57.zip |
fixup the Either monad a bit for type safetyp
Diffstat (limited to 'worker/executor.ts')
-rw-r--r-- | worker/executor.ts | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/worker/executor.ts b/worker/executor.ts index faa40a6..ea580eb 100644 --- a/worker/executor.ts +++ b/worker/executor.ts @@ -36,8 +36,8 @@ export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) => q .get() .fold( - (err, _val) => - jobTypeMetric(tJob.get().type)[err ? "failure" : "success"], + ({ isLeft }) => + jobTypeMetric(tJob.get().type)[isLeft ? "failure" : "success"], ), ), ), @@ -86,7 +86,7 @@ export const executePipeline = ( .get(), ), ); - const failures = jobResults.filter((e) => e.fold((err) => !!err)); + const failures = jobResults.filter((e) => e.fold(( { isLeft }) => isLeft)); if (failures.length > 0) { tJobs.trace.trace(pipelinesMetric.failure); return Either.left(new Error(failures.toString())); |