Consume kinesis logs while task is RUNNING status

pull/218/head
Frostebite 2021-02-07 16:00:59 +00:00
parent 07051a9c9a
commit 93ee50cb1e
2 changed files with 4 additions and 2 deletions

File diff suppressed because one or more lines are too long

View File

@ -140,7 +140,9 @@ class AWS {
})
.promise();
iterator = records.NextShardIterator;
core.info(Buffer.from(records.Records[0].Data).toString('base64'));
core.info(
Buffer.from(Buffer.from(records.Records[0].Data).toString('base64')).toString('base64'),
);
}
await ECS.waitFor('tasksStopped', {