diff options
Diffstat (limited to 'worker/executor.ts')
| -rw-r--r-- | worker/executor.ts | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/worker/executor.ts b/worker/executor.ts index 11c24f6..f9fbf29 100644 --- a/worker/executor.ts +++ b/worker/executor.ts @@ -59,9 +59,9 @@ export const executePipeline = ( .flatMapAsync(TraceUtil.promiseify(TraceUtil.traceResultingEither(metric))); }); const results = await Promise.all(parallelJobs.map((job) => job.get())); - const failures = results.filter((e) => e.left); + const failures = results.filter((e) => e.left().present()); if (failures.length > 0) { - return Either.left(new Error(failures.toString())); + return Either.left(new Error(JSON.stringify(failures))); } } return Either.right(<void>undefined); |