diff --git a/dist/index.js b/dist/index.js index 7509a921..c9d2ab79 100644 Binary files a/dist/index.js and b/dist/index.js differ diff --git a/dist/index.js.map b/dist/index.js.map index 2e698665..c5cdd42a 100644 Binary files a/dist/index.js.map and b/dist/index.js.map differ diff --git a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts index 7b70d72d..45d91424 100644 --- a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts +++ b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts @@ -36,17 +36,20 @@ class KubernetesTaskRunner { const callback = (outputChunk: string) => { output += outputChunk; - // check if log start included in logs if so log a message - if (outputChunk.includes(`Collected Logs`)) { - CloudRunnerLogger.log(`Log Start found in logs`); - } - if (outputChunk.includes(`LOGHASH:`)) { - RemoteClientLogger.HandleLogChunkLine(outputChunk); - CloudRunnerLogger.log(`Loghash found`); - } - if (outputChunk.includes(`LOGS:`)) { - const result = RemoteClientLogger.HandleLogChunkLine(outputChunk); - CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`); + // split output chunk and handle per line + for (const chunk of outputChunk.split(`\n`)) { + // check if log start included in logs if so log a message + if (chunk.includes(`Collected Logs`)) { + CloudRunnerLogger.log(`Log Start found in logs`); + } + if (chunk.includes(`LOGHASH:`)) { + RemoteClientLogger.HandleLogChunkLine(chunk); + CloudRunnerLogger.log(`Loghash found`); + } + if (chunk.includes(`LOGS:`)) { + const result = RemoteClientLogger.HandleLogChunkLine(chunk); + CloudRunnerLogger.log(`Logs found HandleLogChunkLineResult:${result}`); + } } }; try {