diff --git a/pluto-message-ingestion/pluto-message-processor.js b/pluto-message-ingestion/pluto-message-processor.js
index cd843fcda..17b2e39c4 100644
--- a/pluto-message-ingestion/pluto-message-processor.js
+++ b/pluto-message-ingestion/pluto-message-processor.js
@@ -61,7 +61,7 @@ class PlutoMessageProcessor {
         );
 
         // `resolve` to remove message from Kinesis
-        resolve('invalid message, props missing');
+        return resolve('invalid message, props missing');
       }
 
       const project = Object.assign({}, message);