hashed logging k8s
parent
c0f9b06f04
commit
cc57addcc7
|
@ -3982,7 +3982,10 @@ class KubernetesTaskRunner {
|
||||||
for (const chunk of splitLogs) {
|
for (const chunk of splitLogs) {
|
||||||
const message = cloud_runner_1.default.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
|
const message = cloud_runner_1.default.buildParameters.cloudRunnerDebug ? chunk : 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));
|
||||||
follow_log_stream_service_1.FollowLogStreamService.DidReceiveEndOfTransmission = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(message);
|
const result = remote_client_logger_1.RemoteClientLogger.HandleLogChunkLine(message);
|
||||||
|
if (result) {
|
||||||
|
follow_log_stream_service_1.FollowLogStreamService.DidReceiveEndOfTransmission = true;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if (follow_log_stream_service_1.FollowLogStreamService.DidReceiveEndOfTransmission) {
|
if (follow_log_stream_service_1.FollowLogStreamService.DidReceiveEndOfTransmission) {
|
||||||
cloud_runner_logger_1.default.log('end of log stream');
|
cloud_runner_logger_1.default.log('end of log stream');
|
||||||
|
|
File diff suppressed because one or more lines are too long
|
@ -66,7 +66,10 @@ class KubernetesTaskRunner {
|
||||||
shouldCleanup,
|
shouldCleanup,
|
||||||
output,
|
output,
|
||||||
));
|
));
|
||||||
FollowLogStreamService.DidReceiveEndOfTransmission = RemoteClientLogger.HandleLogChunkLine(message);
|
const result = RemoteClientLogger.HandleLogChunkLine(message);
|
||||||
|
if (result) {
|
||||||
|
FollowLogStreamService.DidReceiveEndOfTransmission = true;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
if (FollowLogStreamService.DidReceiveEndOfTransmission) {
|
if (FollowLogStreamService.DidReceiveEndOfTransmission) {
|
||||||
CloudRunnerLogger.log('end of log stream');
|
CloudRunnerLogger.log('end of log stream');
|
||||||
|
|
Loading…
Reference in New Issue