diff options
author | Elizabeth <lizhunt@amazon.com> | 2025-05-28 15:05:38 -0700 |
---|---|---|
committer | Elizabeth <lizhunt@amazon.com> | 2025-05-28 15:05:38 -0700 |
commit | 3005cc83e605fb89b079cf0e6fd0ec95cd27b30e (patch) | |
tree | 992c5933f2ec4a75e32469ddd772c61dbcb2e2fd /worker/executor/job.ts | |
parent | e3cf820b07e282221502cf2f116c9780b7375e0e (diff) | |
download | ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.tar.gz ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.zip |
Run prettier, add zed settings
Diffstat (limited to 'worker/executor/job.ts')
-rw-r--r-- | worker/executor/job.ts | 26 |
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(); |