From 49cdb84fd1546fc7a262d7d3216dc9aa7c08dafe Mon Sep 17 00:00:00 2001 From: Pete F Date: Wed, 11 Dec 2024 10:53:01 +0000 Subject: [PATCH] Return if invalid message, to cease work Co-authored-by: Andrew Nowak <10963046+andrew-nowak@users.noreply.github.com> --- pluto-message-ingestion/pluto-message-processor.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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);