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()));