From 3005cc83e605fb89b079cf0e6fd0ec95cd27b30e Mon Sep 17 00:00:00 2001 From: Elizabeth Date: Wed, 28 May 2025 15:05:38 -0700 Subject: Run prettier, add zed settings --- worker/executor/job.ts | 26 +++++++++++++------------- 1 file changed, 13 insertions(+), 13 deletions(-) (limited to 'worker/executor/job.ts') 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) => - 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(); -- cgit v1.2.3-70-g09d2