If we get an error on the queue make sure we exit with an error #1267

sitespeedio · Nov 6, 2017 · 3108187 · 3108187
1 parent ace34af
commit 3108187
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/core/queueHandler.js b/lib/core/queueHandler.js
@@ -126,6 +126,10 @@ class QueueHandler {
         // FIXME handle rejections (i.e. failures while processing messages) properly
         queue.processingEnded(obj => {
           const message = obj.item;
+          // if we get a error message on the queue make sure we register that
+          if (message.type === 'error' || message.type.endsWith('.error')) {
+            this.errors.push(message.data);
+          }
           const err = obj.err;
           if (err) {
             let rejectionMessage =