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 extends JobQueue { 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 extends JobQueue { 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 extends JobQueue { input: string, runAfter: string | null, deadlineAt: string | null, - maxRetries: number + maxRetries: number, ] >(AddQuery); @@ -183,8 +183,8 @@ export class SqliteJobQueue extends JobQueue { const status = output ? JobStatus.COMPLETED : error && job.retries >= job.maxRetries - ? JobStatus.FAILED - : JobStatus.PENDING; + ? JobStatus.FAILED + : JobStatus.PENDING; const UpdateQuery = ` UPDATE job_queue