v2.0.46-alpha

suredone · May 21, 2024 · 0bd632f · 0bd632f
1 parent 1bd065c
commit 0bd632f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 5 deletions.
diff --git a/npm-shrinkwrap.json b/npm-shrinkwrap.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "qdone",
-  "version": "2.0.45-alpha",
+  "version": "2.0.46-alpha",
   "description": "A distributed scheduler for SQS",
   "type": "module",
   "main": "./index.js",

diff --git a/src/scheduler/jobExecutor.js b/src/scheduler/jobExecutor.js
@@ -169,7 +169,7 @@ export class JobExecutor {
           for (const failed of result.Failed) {
             console.error('FAILED_TO_EXTEND_JOB', { failedEntry: failed, job: this.jobsByMessageId[failed.Id] })
             // ensure that we clean this one up so it doesn't generate api calls
-            this.jobsByMessageId[failed.Id].status = 'failed'
+            if (this.jobsByMessageId[failed.Id]) this.jobsByMessageId[failed.Id].status = 'failed'
           }
         }
         if (result.Successful) {
@@ -213,7 +213,7 @@ export class JobExecutor {
           for (const failed of result.Failed) {
             console.error('FAILED_TO_DELETE_JOB', { failedEntry: failed, job: this.jobsByMessageId[failed.Id] })
             // ensure that we clean this one up so it doesn't generate api calls
-            this.jobsByMessageId[failed.Id].status = 'failed'
+            if (this.jobsByMessageId[failed.Id]) this.jobsByMessageId[failed.Id].status = 'failed'
           }
         }
         if (result.Successful) {