fix: Handle invalid lambda process events

cube-js · Apr 12, 2020 · 37fc43f · 37fc43f
1 parent 37f1b29
commit 37fc43f
Showing 1 changed file with 11 additions and 4 deletions.
diff --git a/packages/cubejs-serverless-aws/index.js b/packages/cubejs-serverless-aws/index.js
@@ -24,10 +24,17 @@ class AWSHandlers extends Handlers {
   }
 
   async process(event) {
-    await Promise.all(event.Records.map(async record => {
-      const message = JSON.parse(record.Sns.Message);
-      await this.processMessage(message);
-    }));
+    if (event.Records) {
+      await Promise.all(event.Records.map(async record => {
+        const message = JSON.parse(record.Sns.Message);
+        await this.processMessage(message);
+      }));
+    } else {
+      this.serverCore.logger('Invalid Lambda Process Message', {
+        warning: `Event doesn't contain Records field. Skipping.`,
+        lambdaEvent: event
+      });
+    }
 
     return {
       statusCode: 200