diff --git a/dist/index.js b/dist/index.js index 4312a4d4..b6e0205a 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 3d986f49..e8169d40 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 b4d923a1..d1b8f01b 100644 --- a/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts +++ b/src/model/cloud-runner/providers/k8s/kubernetes-task-runner.ts @@ -46,12 +46,20 @@ class KubernetesTaskRunner { let lastMessageSeen = false; let logs; + const callback = (outputChunk: string) => { + output += outputChunk; + // check if log start included in logs if so log a message + if (outputChunk.includes(`log start`)) { + CloudRunnerLogger.log(`Log Start found in logs`); + } + }; try { logs = await CloudRunnerSystem.Run( `kubectl logs ${podName}${extraFlags} --timestamps${sinceTime}`, false, true, + callback, ); } catch (error: any) { await new Promise((resolve) => setTimeout(resolve, 3000));