1 files changed, 28 insertions, 20 deletions
diff --git a/hooks/server/job/queuer.ts b/hooks/server/job/queuer.ts
index 6094183..069cca4 100644
--- a/hooks/server/job/queuer.ts
+++ b/hooks/server/job/queuer.ts
@@ -18,15 +18,14 @@ export interface IJobQueuer<TJob> {
 }
 
 export class LaminarJobQueuer
-  implements IJobQueuer<ITraceable<Job, ServerTrace>> {
-  constructor(
-    private readonly queuePositionPrefix: string,
-  ) {}
+  implements IJobQueuer<ITraceable<Job, ServerTrace>>
+{
+  constructor(private readonly queuePositionPrefix: string) {}
 
   private static GetJobTypeTrace = (jobType: string) =>
     `LaminarJobQueue.Queue.${jobType}`;
   private static JobTypeMetrics = memoize((jobType: string) =>
-    Metric.fromName(LaminarJobQueuer.GetJobTypeTrace(jobType))
+    Metric.fromName(LaminarJobQueuer.GetJobTypeTrace(jobType)),
   );
 
   public queue(j: ITraceable<Job, ServerTrace>) {
@@ -50,29 +49,38 @@ export class LaminarJobQueuer
       .peek((c) =>
         c.trace.trace(
           `im so excited to see how this queue job will end!! (>ᴗ<): ${c.get().toString()}`,
-        )
+        ),
       )
       .map(getStdout)
       .peek(
         TraceUtil.promiseify((q) =>
           q.trace.trace(
-            q.get().fold((err, _val) => err ? metric.failure : metric.success),
-          )
+            q
+              .get()
+              .fold((err, _val) => (err ? metric.failure : metric.success)),
+          ),
         ),
       )
-      .map(TraceUtil.promiseify((q) =>
-        q.get().mapRight((stdout) => {
-          q.trace.addTrace(LogLevel.DEBUG).trace(`stdout ${stdout}`);
-          const [jobName, jobId] = stdout.split(":");
-          const jobUrl = `${this.queuePositionPrefix}/jobs/${jobName}/${jobId}`;
+      .map(
+        TraceUtil.promiseify((q) =>
+          q
+            .get()
+            .mapRight((stdout) => {
+              q.trace.addTrace(LogLevel.DEBUG).trace(`stdout ${stdout}`);
+              const [jobName, jobId] = stdout.split(":");
+              const jobUrl = `${this.queuePositionPrefix}/jobs/${jobName}/${jobId}`;
 
-          q.trace.trace(`all queued up and weady to go~ (˘ω˘) => ${jobUrl}`);
-          return jobUrl;
-        }).mapLeft((err) => {
-          q.trace.addTrace(LogLevel.ERROR).trace(err.toString());
-          return err;
-        })
-      ))
+              q.trace.trace(
+                `all queued up and weady to go~ (˘ω˘) => ${jobUrl}`,
+              );
+              return jobUrl;
+            })
+            .mapLeft((err) => {
+              q.trace.addTrace(LogLevel.ERROR).trace(err.toString());
+              return err;
+            }),
+        ),
+      )
       .get();
   }
 }