pull/524/head
Frostebite 2023-03-17 22:09:41 +00:00
parent 0a8fa4679b
commit a0430012e5
3 changed files with 5 additions and 3 deletions

3
dist/index.js generated vendored
View File

@ -3741,6 +3741,7 @@ const core = __importStar(__nccwpck_require__(42186));
const async_wait_until_1 = __importDefault(__nccwpck_require__(41299));
const follow_log_stream_service_1 = __nccwpck_require__(64121);
const cloud_runner_system_1 = __nccwpck_require__(99393);
const cloud_runner_1 = __importDefault(__nccwpck_require__(79144));
class KubernetesTaskRunner {
static async runTask(kubeConfig, kubeClient, jobName, podName, containerName, namespace, alreadyFinished = false) {
cloud_runner_logger_1.default.log(`Streaming logs from pod: ${podName} container: ${containerName} namespace: ${namespace} finished ${alreadyFinished}`);
@ -3762,7 +3763,7 @@ class KubernetesTaskRunner {
const newDate = Date.parse(dateString);
new Date(newDate).toISOString();
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
const message = 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));
}
if (!didStreamAnyLogs) {

2
dist/index.js.map generated vendored

File diff suppressed because one or more lines are too long

View File

@ -4,6 +4,7 @@ import * as core from '@actions/core';
import waitUntil from 'async-wait-until';
import { FollowLogStreamService } from '../../services/follow-log-stream-service';
import { CloudRunnerSystem } from '../../services/cloud-runner-system';
import CloudRunner from '../../cloud-runner';
class KubernetesTaskRunner {
static lastReceivedTimestamp: number;
@ -44,7 +45,7 @@ class KubernetesTaskRunner {
new Date(newDate).toISOString();
KubernetesTaskRunner.lastReceivedTimestamp = newDate;
const message = chunk.split(`Z `)[1];
const message = CloudRunner.buildParameters.cloudRunnerDebug ? chunk : chunk.split(`Z `)[1];
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
message,
shouldReadLogs,