[core] fix formatting

sroussey · Apr 14, 2024 · 9e30048 · 9e30048
1 parent a1c902f
commit 9e30048
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 7 deletions.
diff --git a/packages/core/src/job/PostgreSqlJobQueue.ts b/packages/core/src/job/PostgreSqlJobQueue.ts
@@ -71,8 +71,8 @@ export class PostgreSqlJobQueue<Input, Output> extends JobQueue<Input, Output> {
       return await sql`
         INSERT INTO job_queue(queue, fingerprint, input, runAfter, maxRetries)
           VALUES (${this.queue!}, ${fingerprint}, ${
-        job.input as any
-      }::jsonb, ${job.createdAt.toISOString()}, ${job.maxRetries})
+            job.input as any
+          }::jsonb, ${job.createdAt.toISOString()}, ${job.maxRetries})
           RETURNING id`;
     });
   }
@@ -161,8 +161,8 @@ export class PostgreSqlJobQueue<Input, Output> extends JobQueue<Input, Output> {
     const status = output
       ? JobStatus.COMPLETED
       : error && job.retries >= job.maxRetries
-      ? JobStatus.FAILED
-      : JobStatus.PENDING;
+        ? JobStatus.FAILED
+        : JobStatus.PENDING;
     if (!output || error) job.retries += 1;
     await this.sql.begin(async (sql) => {
       const result = await sql`    

diff --git a/packages/core/src/job/SqliteJobQueue.ts b/packages/core/src/job/SqliteJobQueue.ts
@@ -80,7 +80,7 @@ export class SqliteJobQueue<Input, Output> extends JobQueue<Input, Output> {
         input: string,
         runAfter: string | null,
         deadlineAt: string | null,
-        maxRetries: number
+        maxRetries: number,
       ]
     >(AddQuery);
 
@@ -183,8 +183,8 @@ export class SqliteJobQueue<Input, Output> extends JobQueue<Input, Output> {
     const status = output
       ? JobStatus.COMPLETED
       : error && job.retries >= job.maxRetries
-      ? JobStatus.FAILED
-      : JobStatus.PENDING;
+        ? JobStatus.FAILED
+        : JobStatus.PENDING;
 
     const UpdateQuery = `
         UPDATE job_queue