fixes
parent
af89031a49
commit
de206e2d41
|
@ -3762,7 +3762,7 @@ class KubernetesTaskRunner {
|
|||
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
|
||||
const newDate = Date.parse(dateString);
|
||||
new Date(newDate).toISOString();
|
||||
if (splitLogs[splitLogs.length - 1] !== KubernetesTaskRunner.lastReceivedMessage ||
|
||||
if (chunk !== KubernetesTaskRunner.lastReceivedMessage ||
|
||||
KubernetesTaskRunner.lastReceivedTimestamp < newDate) {
|
||||
started = true;
|
||||
}
|
||||
|
@ -3770,10 +3770,10 @@ class KubernetesTaskRunner {
|
|||
continue;
|
||||
}
|
||||
const message = cloud_runner_1.default.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
|
||||
KubernetesTaskRunner.lastReceivedMessage = chunk;
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
||||
({ shouldReadLogs, shouldCleanup, output } = follow_log_stream_service_1.FollowLogStreamService.handleIteration(message, shouldReadLogs, shouldCleanup, output));
|
||||
}
|
||||
KubernetesTaskRunner.lastReceivedMessage = splitLogs[splitLogs.length - 1];
|
||||
if (!didStreamAnyLogs) {
|
||||
core.error('Failed to stream any logs, listing namespace events, check for an error with the container');
|
||||
core.error(JSON.stringify({
|
||||
|
|
File diff suppressed because one or more lines are too long
|
@ -46,7 +46,7 @@ class KubernetesTaskRunner {
|
|||
const newDate = Date.parse(dateString);
|
||||
new Date(newDate).toISOString();
|
||||
if (
|
||||
splitLogs[splitLogs.length - 1] !== KubernetesTaskRunner.lastReceivedMessage ||
|
||||
chunk !== KubernetesTaskRunner.lastReceivedMessage ||
|
||||
KubernetesTaskRunner.lastReceivedTimestamp < newDate
|
||||
) {
|
||||
started = true;
|
||||
|
@ -55,6 +55,7 @@ class KubernetesTaskRunner {
|
|||
continue;
|
||||
}
|
||||
const message = CloudRunner.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
|
||||
KubernetesTaskRunner.lastReceivedMessage = chunk;
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
||||
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
||||
message,
|
||||
|
@ -63,7 +64,6 @@ class KubernetesTaskRunner {
|
|||
output,
|
||||
));
|
||||
}
|
||||
KubernetesTaskRunner.lastReceivedMessage = splitLogs[splitLogs.length - 1];
|
||||
|
||||
if (!didStreamAnyLogs) {
|
||||
core.error('Failed to stream any logs, listing namespace events, check for an error with the container');
|
||||
|
|
Loading…
Reference in New Issue