Include log chunk when task runner sees log update, clarify if we can pull logs from same line or next line
parent
a760ee803f
commit
5631a3b301
|
@ -3969,7 +3969,9 @@ class KubernetesTaskRunner {
|
||||||
}
|
}
|
||||||
if (chunk.includes(`LOGS:`)) {
|
if (chunk.includes(`LOGS:`)) {
|
||||||
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(chunk);
|
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(chunk);
|
||||||
cloud_runner_logger_1.default.log(`Logs found HandleLogChunkLineResult:${result}\n${chunk}`);
|
// remove "LOGS: " and decode base64 remaining
|
||||||
|
const unpacked = Buffer.from(chunk.split(`LOGS: `)[1], 'base64').toString('ascii');
|
||||||
|
cloud_runner_logger_1.default.log(`Logs found HandleLogChunkLineResult:${result}\n${unpacked}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
File diff suppressed because one or more lines are too long
|
@ -48,7 +48,10 @@ class KubernetesTaskRunner {
|
||||||
}
|
}
|
||||||
if (chunk.includes(`LOGS:`)) {
|
if (chunk.includes(`LOGS:`)) {
|
||||||
const result = RemoteClientLogger.HandleLogChunkLine(chunk);
|
const result = RemoteClientLogger.HandleLogChunkLine(chunk);
|
||||||
CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}\n${chunk}`);
|
|
||||||
|
// remove "LOGS: " and decode base64 remaining
|
||||||
|
const unpacked = Buffer.from(chunk.split(`LOGS: `)[1], 'base64').toString('ascii');
|
||||||
|
CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}\n${unpacked}`);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
Loading…
Reference in New Issue