summaryrefslogtreecommitdiff
path: root/worker/executor/job.ts
diff options
context:
space:
mode:
Diffstat (limited to 'worker/executor/job.ts')
-rw-r--r--worker/executor/job.ts26
1 files changed, 13 insertions, 13 deletions
diff --git a/worker/executor/job.ts b/worker/executor/job.ts
index 76f0e0c..ca7feed 100644
--- a/worker/executor/job.ts
+++ b/worker/executor/job.ts
@@ -12,31 +12,31 @@ import type { Job } from "@emprespresso/ci-model";
const jobTypeMetric = memoize((type: string) => Metric.fromName(`run.${type}`));
export const executeJob = (tJob: ITraceable<Job, LogMetricTraceSupplier>) =>
- tJob.bimap(TraceUtil.withMetricTrace(jobTypeMetric(tJob.get().type)))
+ tJob
+ .bimap(TraceUtil.withMetricTrace(jobTypeMetric(tJob.get().type)))
.peek((tJob) =>
- tJob.trace.trace(
- `let's do this little job ok!! ${tJob.get()}`,
- )
+ tJob.trace.trace(`let's do this little job ok!! ${tJob.get()}`),
)
.map((tJob) =>
validateExecutionEntries(tJob.get().arguments)
.mapLeft((badEntries) => {
- tJob.trace.addTrace(LogLevel.ERROR).trace(
- badEntries.toString(),
- );
+ tJob.trace.addTrace(LogLevel.ERROR).trace(badEntries.toString());
return new Error("invalid job arguments");
})
.flatMapAsync((args) =>
- getStdout(tJob.move(tJob.get().type), { env: args })
- )
+ getStdout(tJob.move(tJob.get().type), { env: args }),
+ ),
)
.peek(
TraceUtil.promiseify((q) =>
q.trace.trace(
- q.get().fold((err, _val) =>
- jobTypeMetric(tJob.get().type)[err ? "failure" : "success"]
- ),
- )
+ q
+ .get()
+ .fold(
+ (err, _val) =>
+ jobTypeMetric(tJob.get().type)[err ? "failure" : "success"],
+ ),
+ ),
),
)
.get();