fixes
parent
6b9984ca54
commit
8ac04dfbcb
|
|
@ -3682,7 +3682,14 @@ class KubernetesTaskRunner {
|
||||||
}
|
}
|
||||||
let lastMessageSeenIncludedInChunk = false;
|
let lastMessageSeenIncludedInChunk = false;
|
||||||
let lastMessageSeen = false;
|
let lastMessageSeen = false;
|
||||||
const logs = await cloud_runner_system_1.CloudRunnerSystem.Run(`kubectl logs ${podName} -f -c ${containerName} --timestamps${sinceTime}`, false, true);
|
let logs;
|
||||||
|
try {
|
||||||
|
logs = await cloud_runner_system_1.CloudRunnerSystem.Run(`kubectl logs ${podName} -f -c ${containerName} --timestamps${sinceTime}`, false, true);
|
||||||
|
}
|
||||||
|
catch (error) {
|
||||||
|
cloud_runner_logger_1.default.log(`K8s logging error ${error}`);
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
const splitLogs = logs.split(`\n`);
|
const splitLogs = logs.split(`\n`);
|
||||||
for (const chunk of splitLogs) {
|
for (const chunk of splitLogs) {
|
||||||
if (chunk.replace(/\s/g, ``) === KubernetesTaskRunner.lastReceivedMessage.replace(/\s/g, ``) &&
|
if (chunk.replace(/\s/g, ``) === KubernetesTaskRunner.lastReceivedMessage.replace(/\s/g, ``) &&
|
||||||
|
|
|
||||||
File diff suppressed because one or more lines are too long
|
|
@ -40,11 +40,18 @@ class KubernetesTaskRunner {
|
||||||
let lastMessageSeenIncludedInChunk = false;
|
let lastMessageSeenIncludedInChunk = false;
|
||||||
let lastMessageSeen = false;
|
let lastMessageSeen = false;
|
||||||
|
|
||||||
const logs = await CloudRunnerSystem.Run(
|
let logs;
|
||||||
|
|
||||||
|
try {
|
||||||
|
logs = await CloudRunnerSystem.Run(
|
||||||
`kubectl logs ${podName} -f -c ${containerName} --timestamps${sinceTime}`,
|
`kubectl logs ${podName} -f -c ${containerName} --timestamps${sinceTime}`,
|
||||||
false,
|
false,
|
||||||
true,
|
true,
|
||||||
);
|
);
|
||||||
|
} catch (error: any) {
|
||||||
|
CloudRunnerLogger.log(`K8s logging error ${error}`);
|
||||||
|
throw error;
|
||||||
|
}
|
||||||
const splitLogs = logs.split(`\n`);
|
const splitLogs = logs.split(`\n`);
|
||||||
for (const chunk of splitLogs) {
|
for (const chunk of splitLogs) {
|
||||||
if (
|
if (
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue