diff options
Diffstat (limited to 'server/job.ts')
| -rw-r--r-- | server/job.ts | 9 |
1 files changed, 5 insertions, 4 deletions
diff --git a/server/job.ts b/server/job.ts index 06359d1..42d40fd 100644 --- a/server/job.ts +++ b/server/job.ts @@ -27,13 +27,14 @@ const jobJsonTransformer = ( ): IEither<PenguenoError, Job> => j .bimap(TraceUtil.withMetricTrace(wellFormedJobMetric)) - .map((tJson) => { - if (!isJob(tJson) || !validateExecutionEntries(tJson)) { + .map((tJson): IEither<PenguenoError, Job> => { + const tJob = tJson.get(); + if (!isJob(tJob) || !validateExecutionEntries(tJob)) { const err = "seems like a pwetty mawfomed job (-.-)"; tJson.trace.addTrace(LogLevel.WARN).trace(err); - return Either.left<PenguenoError, Job>(new PenguenoError(err, 400)); + return Either.left(new PenguenoError(err, 400)); } - return Either.right<PenguenoError, Job>(tJson); + return Either.right(tJob); }) .peek((tJob) => tJob.trace.trace( |