correction to cloud formation

pull/218/head
Frostebite 2021-02-12 22:00:28 +00:00 committed by GitHub
parent e0433c385a
commit e163c51be2
2 changed files with 16 additions and 7 deletions

File diff suppressed because one or more lines are too long

View File

@ -126,10 +126,14 @@ class AWS {
core.info('Build job is starting'); core.info('Build job is starting');
await ECS.waitFor('tasksRunning', { try {
cluster: clusterName, await ECS.waitFor('tasksRunning', {
tasks: [task.tasks[0].taskArn], cluster: clusterName,
}).promise(); tasks: [task.tasks[0].taskArn],
}).promise();
} catch (error) {
core.error(error);
}
core.info(`Build job is running`); core.info(`Build job is running`);
@ -163,7 +167,13 @@ class AWS {
).ShardIterator; ).ShardIterator;
core.info(`Task status is ${await getTaskStatus()}`); core.info(`Task status is ${await getTaskStatus()}`);
while ((await getTaskStatus()) === 'RUNNING') { let readingLogs = true;
while (readingLogs) {
await new Promise((resolve) => setTimeout(resolve, 3000));
if ((await getTaskStatus()) === 'RUNNING') {
readingLogs = false;
await new Promise((resolve) => setTimeout(resolve, 13000));
}
const records = await kinesis const records = await kinesis
.getRecords({ .getRecords({
ShardIterator: iterator, ShardIterator: iterator,
@ -182,7 +192,6 @@ class AWS {
} }
} }
} }
await new Promise((resolve) => setTimeout(resolve, 3000));
} }
await ECS.waitFor('tasksStopped', { await ECS.waitFor('tasksStopped', {