From 3005cc83e605fb89b079cf0e6fd0ec95cd27b30e Mon Sep 17 00:00:00 2001
From: Elizabeth <lizhunt@amazon.com>
Date: Wed, 28 May 2025 15:05:38 -0700
Subject: Run prettier, add zed settings

---
 worker/executor/pipeline.ts | 27 ++++++++++++++++-----------
 1 file changed, 16 insertions(+), 11 deletions(-)

(limited to 'worker/executor/pipeline.ts')

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));
-- 
cgit v1.2.3-70-g09d2