From 9e30048f669f078e50977b5e69469a6839b91d4d Mon Sep 17 00:00:00 2001
From: Steven Roussey <sroussey@gmail.com>
Date: Sun, 14 Apr 2024 12:32:02 -0700
Subject: [PATCH] [core] fix formatting

---
 packages/core/src/job/PostgreSqlJobQueue.ts | 8 ++++----
 packages/core/src/job/SqliteJobQueue.ts     | 6 +++---
 2 files changed, 7 insertions(+), 7 deletions(-)

diff --git a/packages/core/src/job/PostgreSqlJobQueue.ts b/packages/core/src/job/PostgreSqlJobQueue.ts
index b526109..f990a89 100644
--- 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
index 52b07eb..5de8fb1 100644
--- 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