check for empty kinesis stream

2021-02-07 16:24:06 +00:00 · 2021-02-07 16:24:06 +00:00 · 4fee759b56
parent dadb015f3f
commit 4fee759b56
1 changed files with 3 additions and 3 deletions
--- a/src/model/aws.js
+++ b/src/model/aws.js
@ -139,9 +139,9 @@ class AWS {
        })
        .promise();
      iterator = records.NextShardIterator;
-      core.info(
-        Buffer.from(Buffer.from(records.Records[0].Data).toString('base64')).toString('base64'),
-      );
+      if (records.Records.length > 0){
+        core.info(Buffer.from(records.Records[0].Data).toString('base64'));
+      }
    }

    await ECS.waitFor('tasksStopped', {