summaryrefslogtreecommitdiff
path: root/worker/executor.ts
diff options
context:
space:
mode:
authorElizabeth <me@liz.coffee>2025-06-02 16:52:52 -0700
committerElizabeth <me@liz.coffee>2025-06-02 16:52:52 -0700
commit98f5c21aa65bbbca01a186a754249335b4afef57 (patch)
tree0fc8e01a73f0a3be4534c11724ad2ff634b4fd2f /worker/executor.ts
parent373d9ec700c0097a22cf665a8e33cf48998d1dc2 (diff)
downloadci-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.ts6
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()));