From c658a08c003ad4c2c2a6e1619e7c206f910ec546 Mon Sep 17 00:00:00 2001 From: Frostebite Date: Mon, 14 Aug 2023 22:35:49 +0100 Subject: [PATCH] hashed logs --- dist/index.js | Bin 19466225 -> 19466569 bytes dist/index.js.map | Bin 13766172 -> 13766572 bytes .../providers/k8s/kubernetes-task-runner.ts | 8 ++++++++ 3 files changed, 8 insertions(+) diff --git a/dist/index.js b/dist/index.js index 4312a4d42b914b43c116474bcab2a83f7fe47c9e..b6e0205a0f3baa35ef923dc4569487169d91dc1d 100644 GIT binary patch delta 1455 zcmX}scU;tU9LMnox8T^wI`$nqQ$(q3qfyYHLeX+m9vRG&*ztM+uY1+U67=~Rx!km5>h zF)06OnoL#Et~b;Vv}&M*4tmI$J3L^7C%oVdANax#{s_P%1R@B*2tg=J2tzm`5Q!*6 zBL-$z5Q{j(BLRs>LNd<6WSosDn2HokLn@|Y2GVd2&c%6{iSuy*F2qH+7?Qddg;<2exCuAo7A%1kdAJq% zC_o{KP>iK0!EGo-8E!{8Y^cB;sDvF3IB_TL!rizB%WyB2<38MvDpX?y9>7Y}pcZwg z$Af6VLukaqcm$843C(y6EpVX~k7E@S+VBLP#8X&}HE74vcm^GK7SEv*Yq1W`;|08k z_2|M&=*9+Y#3pRU7WAMOTd@t>u>(8tGG4)}cnz;(7j|P0_Tmk^iMQ}J-oZZfVLuMw zAl^kk-oyL&03YHbe2h=$-QM&$w`yb79{3Zq;~I1=BEl~CQ4E{g^BD` z^{lM)RQ1@5&J|tDGgG-;61`K?O0qLciz^eQI*)a;Zms8jwdr z@+qJZjcGztn$es>TF{bK6w#VCw51*GIf#Slz#(*`6P@WoR}Q5chjBQ?96@)E=a}$I+AHIe}iB$Vr?`Z%&~Ped$Mk25>5;aXM#kCTDRr=Ws6PaXuF?kP8{aV1{rJ zLm9@!4CfL?Fp^PR%4J;66-e5T^Sjj3@^CoL}i?>|rmz@GHOZJAbf`KlzKl`GcX9ns|`;c-ODP11oy zhscpTGxeh(KlFl>;)fMfIwe?F&wVE>7TPa$`d4$$! zhbhXEi(ML;6Z{nREAFlxiU!xj7=_5$>F!bxt1XGuDlh;8;ebJKgcAnC8A`Zd2!>)9 zhQk$Z7=e*+hX*|21#kF3WslXWlfH`Y4w9pnUS~9>==53gY&pPev*y^W(HS;Vmgo+Q zR0-EMwNlu+BuUg(`8Y&|gvj~~1G|}NveBF_TdcZVtDI@l8*QnER1ST&mcFUQ+`pic zvkexDF5MtX3sv6Ycc=@=GyMw-U9aRW zdh^ttqV;EloA~u!?IYTPq#|XY{O=c{(mzroe4T5Y#K|UKXOY~f9xf*DQz?b1Qxzrh zf2anFoUSlsNl&nZQ5X$h$QXmM&|n<=;E(YLzywUhBm^P|!3e=*gklP&A`H_Ij_HWN z3`AlkW??qwU@oFC5AzX?1&F~yEW%QIjcJitRdf*p_X1W(b3CN!f3&(MnJc!4&EhU8?@ss V-r+qy;3GcaGdk=&!C%6^{Q(7N4V?f0 delta 956 zcmWm0X;(~f0KnlhOqUw%L(QGa7?iz>NY+Rs+qD&woXcm3NvLtNXvO&0h$$HW9Qw|l1)u9LVZOBFrwqpl&Vi$6;8+(w4z1WBSu;2g=;t&qQiX%9RV>pg{oWMz(!fBj=4QEk+ zLYzYp&Z8J5u;T(Q;u0?73a;WBuA>xXC`Scu;3jTC;5P1{5>;^EE~-(3d$^AWc!*lm z;SnC=37+B^p2LZHyueGi@CprZ<2Bx(5gs(58E^3p@9_aGXvIf-LL1ug86Eh7ukfN1 UUHFD>d`Ay@(dV%${RspA0AZthJpcdz 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));