governor-agent - npm Package Compare versions

Comparing version 1.1.0 to 1.2.0

lib/job.js

@@ -95,9 +95,11 @@ 'use strict';
 
-        self.handleTask(task, ack, function () {
+        self.handleTask(task, ack, function (requeueAction) {
             self.nacks.mark();
 
             if (self.delayTime > 1) {
-                setTimeout(nack, self.delayTime);
+                setTimeout(function () {
+                    nack(requeueAction);
+                }, self.delayTime);
             } else {
-                nack();
+                nack(requeueAction);
             }
@@ -124,3 +126,3 @@ });
             clearTimeout(slowTimeout);
-            nack();
+            nack(err.deadletter == true ? 'deadletter' : 'requeue');
             self.agent.net.endJob(jobId, generatedLocks);
@@ -181,2 +183,3 @@ log.error({err: err}, 'Task erred');
         self.agent.log.error({err: err, job: self.name}, 'Task failed');
+        // todo: should this deadletter the task?
         nack();
@@ -183,0 +186,0 @@ });

package.json

 {
   "name": "governor-agent",
-  "version": "1.1.0",
+  "version": "1.2.0",
   "description": "Agent library to connect worker to governor",
@@ -5,0 +5,0 @@ "main": "index.js",

No alert changes

Improved metrics

Total package byte prevSize

23939

increased by0.81%

Lines of code

536

increased by0.56%

No dependency changes