diff options
author | Elizabeth Hunt <me@liz.coffee> | 2025-06-15 11:26:09 -0700 |
---|---|---|
committer | Elizabeth Hunt <me@liz.coffee> | 2025-06-15 11:26:09 -0700 |
commit | f00ea8a615f314b0e2aba38ee883ab1bf12b5827 (patch) | |
tree | 760a2b66665795f59653348edb42ef092f8beff8 | |
parent | cfbd074b8f593ea464dcbeae210eea4b86ec93a3 (diff) | |
download | ci-f00ea8a615f314b0e2aba38ee883ab1bf12b5827.tar.gz ci-f00ea8a615f314b0e2aba38ee883ab1bf12b5827.zip |
Fix job validation
-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( |