Consume kinesis logs while task is RUNNING status

pull/218/head
Frostebite 2021-02-07 16:03:25 +00:00
parent 93ee50cb1e
commit 31a35f9677
2 changed files with 2 additions and 2 deletions

File diff suppressed because one or more lines are too long

View File

@ -136,7 +136,7 @@ class AWS {
while ((await getTaskStatus()) === 'RUNNING') { while ((await getTaskStatus()) === 'RUNNING') {
const records = await kinesis const records = await kinesis
.getRecords({ .getRecords({
ShardIterator: iterator.ShardIterator, ShardIterator: iterator,
}) })
.promise(); .promise();
iterator = records.NextShardIterator; iterator = records.NextShardIterator;