actions
/
unity-builder
mirror of https://github.com/game-ci/unity-builder.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

cleanup

pull/496/head
Frostebite 2023-03-06 18:42:39 +00:00
parent f5bd8a7dde
commit 8e2df47c7f
3 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
dist/index.js vendored
View File

@ -4050,6 +4050,7 @@ class KubernetesTaskRunner {
let shouldCleanup = true; let shouldCleanup = true;
stream._write = (chunk, encoding, next) => { stream._write = (chunk, encoding, next) => {
didStreamAnyLogs = true; didStreamAnyLogs = true;
KubernetesTaskRunner.lastReceivedTimestamp = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
const message = chunk.toString().split(`Z `)[1].trimRight(`\n`); const message = chunk.toString().split(`Z `)[1].trimRight(`\n`);
({ 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));
next(); next();

2
dist/index.js.map vendored
View File

File diff suppressed because one or more lines are too long

3
src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts
View File

@ -7,7 +7,7 @@ import { FollowLogStreamService } from '../../services/follow-log-stream-service
import { CloudRunnerSystem } from '../../services/cloud-runner-system'; import { CloudRunnerSystem } from '../../services/cloud-runner-system';
class KubernetesTaskRunner { class KubernetesTaskRunner {
static lastReceivedTimestamp: number; static lastReceivedTimestamp: Date;
static async runTask( static async runTask(
kubeConfig: KubeConfig, kubeConfig: KubeConfig,
kubeClient: CoreV1Api, kubeClient: CoreV1Api,
@ -27,6 +27,7 @@ class KubernetesTaskRunner {
let shouldCleanup = true; let shouldCleanup = true;
stream._write = (chunk, encoding, next) => { stream._write = (chunk, encoding, next) => {
didStreamAnyLogs = true; didStreamAnyLogs = true;
KubernetesTaskRunner.lastReceivedTimestamp = new Date(`${chunk.toString().split(`Z `)[0]}Z`);
const message = chunk.toString().split(`Z `)[1].trimRight(`\n`); const message = chunk.toString().split(`Z `)[1].trimRight(`\n`);
({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration( ({ shouldReadLogs, shouldCleanup, output } = FollowLogStreamService.handleIteration(
message, message,