fix(job): deserialize priority in fromJSON (#3126)

taskforcesh · Mar 8, 2025 · c3269b1 · c3269b1
1 parent 707853c
commit c3269b1
Show file tree

Hide file tree

Showing 3 changed files with 9 additions and 1 deletion.
diff --git a/src/classes/job.ts b/src/classes/job.ts
@@ -349,6 +349,8 @@ export class Job<
 
     job.delay = parseInt(json.delay);
 
+    job.priority = parseInt(json.priority);
+
     job.timestamp = parseInt(json.timestamp);
 
     if (json.finishedOn) {

diff --git a/src/interfaces/job-json.ts b/src/interfaces/job-json.ts
@@ -34,6 +34,7 @@ export interface JobJsonRaw {
   attemptsMade?: string;
   finishedOn?: string;
   processedOn?: string;
+  priority: string;
   timestamp: string;
   failedReason: string;
   stacktrace: string[];

diff --git a/tests/test_job.ts b/tests/test_job.ts
@@ -1164,7 +1164,12 @@ describe('Job', function () {
 
         const worker = new Worker(
           queueName,
-          async () => {
+          async (job: Job) => {
+            if (job.name === 'test1') {
+              expect(job.priority).to.be.eql(8);
+            } else {
+              expect(job.priority).to.be.eql(1);
+            }
             await delay(20);
           },
           { connection, prefix },