Run prettier, add zed settings

2 files changed, 29 insertions, 24 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();
diff --git a/worker/executor/pipeline.ts b/worker/executor/pipeline.ts
index a1aa7c3..c8423b1 100644
--- a/worker/executor/pipeline.ts
+++ b/worker/executor/pipeline.ts
@@ -14,7 +14,8 @@ export const executePipeline = (
   tPipeline: ITraceable<Pipeline, LogMetricTraceSupplier>,
   baseEnv?: JobArgT,
 ): Promise<IEither<Error, void>> =>
-  tPipeline.bimap(TraceUtil.withFunctionTrace(executePipeline))
+  tPipeline
+    .bimap(TraceUtil.withFunctionTrace(executePipeline))
     .bimap(TraceUtil.withMetricTrace(pipelinesMetric))
     .map(async (tJobs): Promise<IEither<Error, void>> => {
       for (const [i, serialStage] of tJobs.get().serialJobs.entries()) {
@@ -23,22 +24,26 @@ export const executePipeline = (
         );
         const jobResults = await Promise.all(
           serialStage.parallelJobs.map((job) =>
-            tJobs.bimap((_) => [job, `stage ${i}`])
-              .map((tJob) =>
-                <Job> ({
-                  ...tJob.get(),
-                  arguments: { ...baseEnv, ...tJob.get().arguments },
-                })
+            tJobs
+              .bimap((_) => [job, `stage ${i}`])
+              .map(
+                (tJob) =>
+                  <Job>{
+                    ...tJob.get(),
+                    arguments: { ...baseEnv, ...tJob.get().arguments },
+                  },
               )
               .map(executeJob)
               .peek(
                 TraceUtil.promiseify((tEitherJobOutput) =>
-                  tEitherJobOutput.get().mapRight((stdout) =>
-                    tEitherJobOutput.trace.addTrace("STDOUT").trace(stdout)
-                  )
+                  tEitherJobOutput
+                    .get()
+                    .mapRight((stdout) =>
+                      tEitherJobOutput.trace.addTrace("STDOUT").trace(stdout),
+                    ),
                 ),
               )
-              .get()
+              .get(),
           ),
         );
         const failures = jobResults.filter((e) => e.fold((err) => !!err));