pull/524/head
Frostebite 2023-03-18 01:58:11 +00:00
parent 217eaabf4f
commit 1a077d20dd
3 changed files with 7 additions and 13 deletions

9
dist/index.js generated vendored
View File

@ -3762,18 +3762,15 @@ class KubernetesTaskRunner {
lastMessageSeenIncludedInChunk = true; lastMessageSeenIncludedInChunk = true;
} }
} }
for (const element of splitLogs) { for (const chunk of splitLogs) {
didStreamAnyLogs = true; const newDate = Date.parse(`${chunk.toString().split(`Z `)[0]}Z`);
const chunk = element;
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
const newDate = Date.parse(dateString);
new Date(newDate).toISOString();
if (chunk === KubernetesTaskRunner.lastReceivedMessage) { if (chunk === KubernetesTaskRunner.lastReceivedMessage) {
lastMessageSeen = true; lastMessageSeen = true;
} }
if (lastMessageSeenIncludedInChunk && !lastMessageSeen) { if (lastMessageSeenIncludedInChunk && !lastMessageSeen) {
continue; continue;
} }
didStreamAnyLogs = true;
const message = cloud_runner_1.default.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1]; const message = cloud_runner_1.default.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
KubernetesTaskRunner.lastReceivedMessage = chunk; KubernetesTaskRunner.lastReceivedMessage = chunk;
KubernetesTaskRunner.lastReceivedTimestamp = newDate; KubernetesTaskRunner.lastReceivedTimestamp = newDate;

2
dist/index.js.map generated vendored

File diff suppressed because one or more lines are too long

View File

@ -45,18 +45,15 @@ class KubernetesTaskRunner {
lastMessageSeenIncludedInChunk = true; lastMessageSeenIncludedInChunk = true;
} }
} }
for (const element of splitLogs) { for (const chunk of splitLogs) {
didStreamAnyLogs = true; const newDate = Date.parse(`${chunk.toString().split(`Z `)[0]}Z`);
const chunk = element;
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
const newDate = Date.parse(dateString);
new Date(newDate).toISOString();
if (chunk === KubernetesTaskRunner.lastReceivedMessage) { if (chunk === KubernetesTaskRunner.lastReceivedMessage) {
lastMessageSeen = true; lastMessageSeen = true;
} }
if (lastMessageSeenIncludedInChunk && !lastMessageSeen) { if (lastMessageSeenIncludedInChunk && !lastMessageSeen) {
continue; continue;
} }
didStreamAnyLogs = true;
const message = CloudRunner.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1]; const message = CloudRunner.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
KubernetesTaskRunner.lastReceivedMessage = chunk; KubernetesTaskRunner.lastReceivedMessage = chunk;
KubernetesTaskRunner.lastReceivedTimestamp = newDate; KubernetesTaskRunner.lastReceivedTimestamp = newDate;