pull/235/head
mdugdale 2021-04-07 21:50:20 +01:00
parent 3052f7f685
commit 8d8f10f6f6
3 changed files with 19 additions and 7 deletions

12
dist/index.js vendored
View File

@ -663,12 +663,18 @@ class AWS {
const timestampReady = (t1, t2, tlimit) => {
return t2 - t1 / 1000 < tlimit;
};
let timestamp = 0;
while (readingLogs) {
yield new Promise((resolve) => setTimeout(resolve, 1500));
const taskData = yield getTaskData();
if ((taskData === null || taskData === void 0 ? void 0 : taskData.lastStatus) !== 'RUNNING' && timestampReady(taskData === null || taskData === void 0 ? void 0 : taskData.stoppedAt, Date.now(), 30)) {
core.info('Task status is not RUNNING for 30 seconds, last query for logs');
readingLogs = false;
if ((taskData === null || taskData === void 0 ? void 0 : taskData.lastStatus) !== 'RUNNING') {
if (timestamp == 0) {
timestamp = Date.now();
}
if (timestampReady(timestamp, Date.now(), 30)) {
core.info('Task status is not RUNNING for 30 seconds, last query for logs');
readingLogs = false;
}
}
const records = yield kinesis
.getRecords({

2
dist/index.js.map vendored

File diff suppressed because one or more lines are too long

View File

@ -540,12 +540,18 @@ class AWS {
const timestampReady = (t1, t2, tlimit) => {
return t2 - t1 / 1000 < tlimit;
};
let timestamp: number = 0;
while (readingLogs) {
await new Promise((resolve) => setTimeout(resolve, 1500));
const taskData = await getTaskData();
if (taskData?.lastStatus !== 'RUNNING' && timestampReady(taskData?.stoppedAt, Date.now(), 30)) {
core.info('Task status is not RUNNING for 30 seconds, last query for logs');
readingLogs = false;
if (taskData?.lastStatus !== 'RUNNING') {
if (timestamp == 0) {
timestamp = Date.now();
}
if (timestampReady(timestamp, Date.now(), 30)) {
core.info('Task status is not RUNNING for 30 seconds, last query for logs');
readingLogs = false;
}
}
const records = await kinesis
.getRecords({