fixes
parent
8e2df47c7f
commit
45597ae5c6
|
|
@ -4050,7 +4050,13 @@ class KubernetesTaskRunner {
|
|||
let shouldCleanup = true;
|
||||
stream._write = (chunk, encoding, next) => {
|
||||
didStreamAnyLogs = true;
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
|
||||
try {
|
||||
const newData = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = newData;
|
||||
}
|
||||
catch (_a) {
|
||||
/* */
|
||||
}
|
||||
const message = chunk.toString().split(`Z `)[1].trimRight(`\n`);
|
||||
({ shouldReadLogs, shouldCleanup, output } = follow_log_stream_service_1.FollowLogStreamService.handleIteration(message, shouldReadLogs, shouldCleanup, output));
|
||||
next();
|
||||
|
|
|
|||
File diff suppressed because one or more lines are too long
|
|
@ -27,7 +27,13 @@ class KubernetesTaskRunner {
|
|||
let shouldCleanup = true;
|
||||
stream._write = (chunk, encoding, next) => {
|
||||
didStreamAnyLogs = true;
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
|
||||
try {
|
||||
const newData = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
|
||||
KubernetesTaskRunner.lastReceivedTimestamp = newData;
|
||||
} catch {
|
||||
/* */
|
||||
}
|
||||
|
||||
const message = chunk.toString().split(`Z `)[1].trimRight(`\n`);
|
||||
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
||||
message,
|
||||
|
|
|
|||
Loading…
Reference in New Issue