summaryrefslogtreecommitdiff
path: root/server/job.ts
diff options
context:
space:
mode:
Diffstat (limited to 'server/job.ts')
-rw-r--r--server/job.ts4
1 files changed, 2 insertions, 2 deletions
diff --git a/server/job.ts b/server/job.ts
index af11ac0..06359d1 100644
--- a/server/job.ts
+++ b/server/job.ts
@@ -29,7 +29,7 @@ const jobJsonTransformer = (
.bimap(TraceUtil.withMetricTrace(wellFormedJobMetric))
.map((tJson) => {
if (!isJob(tJson) || !validateExecutionEntries(tJson)) {
- const err = "seems like a pwetty mawfomed job \\(-.-)/";
+ const err = "seems like a pwetty mawfomed job (-.-)";
tJson.trace.addTrace(LogLevel.WARN).trace(err);
return Either.left<PenguenoError, Job>(new PenguenoError(err, 400));
}
@@ -70,7 +70,7 @@ export class JobHookActivityImpl implements IJobHookActivity {
return eitherJob.flatMapAsync(async (job) => {
const eitherQueued = await tEitherJobJson
.move(job)
- .map(this.queuer.queue)
+ .map((job) => this.queuer.queue(job))
.get();
return eitherQueued.mapLeft((e) => new PenguenoError(e.message, 500));
});