fixes
parent
96ca464c8a
commit
c4e311f643
|
|
@ -3760,15 +3760,10 @@ class KubernetesTaskRunner {
|
||||||
for (const element of splitLogs) {
|
for (const element of splitLogs) {
|
||||||
didStreamAnyLogs = true;
|
didStreamAnyLogs = true;
|
||||||
const chunk = element;
|
const chunk = element;
|
||||||
try {
|
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
|
||||||
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
|
const newDate = Date.parse(dateString);
|
||||||
const newDate = Date.parse(dateString);
|
new Date(newDate).toISOString();
|
||||||
new Date(newDate).toISOString();
|
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
||||||
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
|
||||||
}
|
|
||||||
catch {
|
|
||||||
/* */
|
|
||||||
}
|
|
||||||
const message = chunk.split(`Z `)[1];
|
const message = chunk.split(`Z `)[1];
|
||||||
({ shouldReadLogs, shouldCleanup, output } = follow_log_stream_service_1.FollowLogStreamService.handleIteration(message, shouldReadLogs, shouldCleanup, output));
|
({ shouldReadLogs, shouldCleanup, output } = follow_log_stream_service_1.FollowLogStreamService.handleIteration(message, shouldReadLogs, shouldCleanup, output));
|
||||||
}
|
}
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -39,14 +39,10 @@ class KubernetesTaskRunner {
|
||||||
for (const element of splitLogs) {
|
for (const element of splitLogs) {
|
||||||
didStreamAnyLogs = true;
|
didStreamAnyLogs = true;
|
||||||
const chunk = element;
|
const chunk = element;
|
||||||
try {
|
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
|
||||||
const dateString = `${chunk.toString().split(`Z `)[0]}Z`;
|
const newDate = Date.parse(dateString);
|
||||||
const newDate = Date.parse(dateString);
|
new Date(newDate).toISOString();
|
||||||
new Date(newDate).toISOString();
|
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
||||||
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
|
|
||||||
} catch {
|
|
||||||
/* */
|
|
||||||
}
|
|
||||||
|
|
||||||
const message = chunk.split(`Z `)[1];
|
const message = chunk.split(`Z `)[1];
|
||||||
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue