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 /hooks/server/job/queuer.ts | |
parent | e3cf820b07e282221502cf2f116c9780b7375e0e (diff) | |
download | ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.tar.gz ci-3005cc83e605fb89b079cf0e6fd0ec95cd27b30e.zip |
Run prettier, add zed settings
Diffstat (limited to 'hooks/server/job/queuer.ts')
-rw-r--r-- | hooks/server/job/queuer.ts | 48 |
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(); } } |