hashed logging k8s
parent
51c1da5a82
commit
368f63e404
|
@ -3961,6 +3961,14 @@ class KubernetesTaskRunner {
|
||||||
if (outputChunk.includes(`Collected Logs`)) {
|
if (outputChunk.includes(`Collected Logs`)) {
|
||||||
cloud_runner_logger_1.default.log(`Log Start found in logs`);
|
cloud_runner_logger_1.default.log(`Log Start found in logs`);
|
||||||
}
|
}
|
||||||
|
if (outputChunk.includes(`LOGHASH:`)) {
|
||||||
|
remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(outputChunk);
|
||||||
|
cloud_runner_logger_1.default.log(`Loghash found`);
|
||||||
|
}
|
||||||
|
if (outputChunk.includes(`LOGS:`)) {
|
||||||
|
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(outputChunk);
|
||||||
|
cloud_runner_logger_1.default.log(`Logs found HandleLogChunkLineResult:${result}`);
|
||||||
|
}
|
||||||
};
|
};
|
||||||
try {
|
try {
|
||||||
logs = await cloud_runner_system_1.CloudRunnerSystem.Run(`kubectl logs ${podName}${extraFlags}`, false, true, callback);
|
logs = await cloud_runner_system_1.CloudRunnerSystem.Run(`kubectl logs ${podName}${extraFlags}`, false, true, callback);
|
||||||
|
|
File diff suppressed because one or more lines are too long
|
@ -40,6 +40,14 @@ class KubernetesTaskRunner {
|
||||||
if (outputChunk.includes(`Collected Logs`)) {
|
if (outputChunk.includes(`Collected Logs`)) {
|
||||||
CloudRunnerLogger.log(`Log Start found in logs`);
|
CloudRunnerLogger.log(`Log Start found in logs`);
|
||||||
}
|
}
|
||||||
|
if (outputChunk.includes(`LOGHASH:`)) {
|
||||||
|
RemoteClientLogger.HandleLogChunkLine(outputChunk);
|
||||||
|
CloudRunnerLogger.log(`Loghash found`);
|
||||||
|
}
|
||||||
|
if (outputChunk.includes(`LOGS:`)) {
|
||||||
|
const result = RemoteClientLogger.HandleLogChunkLine(outputChunk);
|
||||||
|
CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`);
|
||||||
|
}
|
||||||
};
|
};
|
||||||
try {
|
try {
|
||||||
logs = await CloudRunnerSystem.Run(`kubectl logs ${podName}${extraFlags}`, false, true, callback);
|
logs = await CloudRunnerSystem.Run(`kubectl logs ${podName}${extraFlags}`, false, true, callback);
|
||||||
|
|
Loading…
Reference in New Issue