add error handling

Author: andrewjschuang

components/aws/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@pipedream/aws",
-  "version": "0.7.6",
+  "version": "0.7.7",
   "description": "Pipedream Aws Components",
   "main": "aws.app.mjs",
   "keywords": [

components/aws/sources/new-dynamodb-stream-event/new-dynamodb-stream-event.mjs

@@ -6,7 +6,7 @@ export default {
   name: "New DynamoDB Stream Event",
   description: "Emit new event when a DynamoDB stream receives new events. [See the docs here](https://docs.aws.amazon.com/amazondynamodb/latest/APIReference/API_streams_GetRecords.html)",
   type: "source",
-  version: "0.0.3",
+  version: "0.0.4",
   dedupe: "unique",
   props: {
     ...common.props,
@@ -75,21 +75,26 @@ export default {
       throw new Error("Stream is no longer enabled.");
     }
 
-    const shardIterator = this._getShardIterator() ?? (await this._getNewShardIterator());
+    const shardIterator = this._getShardIterator();
 
-    const {
-      Records: records, NextShardIterator: nextShardIterator,
-    } = await this.getRecords({
-      ShardIterator: shardIterator,
-    });
+    try {
+      const {
+        Records: records,
+        NextShardIterator: nextShardIterator,
+      } = await this.getRecords({
+        ShardIterator: shardIterator,
+      });
 
-    for (const record of records) {
-      const meta = this.generateMeta(record);
-      this.$emit(record, meta);
-    }
+      for (const record of records) {
+        const meta = this.generateMeta(record);
+        this.$emit(record, meta);
+      }
 
-    if (nextShardIterator) {
       this._setShardIterator(nextShardIterator);
+    } catch (e) {
+      console.log("Error getting records", e);
+      console.log("Retrieving a new shard iterator");
+      await this._getNewShardIterator();
     }
   },
 };