Fix exit flow for k8s job
parent
534c94e159
commit
6c6866f27e
|
@ -3997,7 +3997,7 @@ class KubernetesTaskRunner {
|
||||||
// if line contains "LOGS: " then stop
|
// if line contains "LOGS: " then stop
|
||||||
if (message.includes(`LOGS:`)) {
|
if (message.includes(`LOGS:`)) {
|
||||||
cloud_runner_logger_1.default.log(`LOGS: found`);
|
cloud_runner_logger_1.default.log(`LOGS: found`);
|
||||||
break;
|
continue;
|
||||||
}
|
}
|
||||||
({ 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));
|
||||||
const result = remote_client_logger_1.RemoteClientLogger.HandleLog(message);
|
const result = remote_client_logger_1.RemoteClientLogger.HandleLog(message);
|
||||||
|
|
File diff suppressed because one or more lines are too long
|
@ -77,7 +77,7 @@ class KubernetesTaskRunner {
|
||||||
// if line contains "LOGS: " then stop
|
// if line contains "LOGS: " then stop
|
||||||
if (message.includes(`LOGS:`)) {
|
if (message.includes(`LOGS:`)) {
|
||||||
CloudRunnerLogger.log(`LOGS: found`);
|
CloudRunnerLogger.log(`LOGS: found`);
|
||||||
break;
|
continue;
|
||||||
}
|
}
|
||||||
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
|
||||||
message,
|
message,
|
||||||
|
|
Loading…
Reference in New Issue