From 00a2e776435becb8a179d67d19d2c9bd7b46ac66 Mon Sep 17 00:00:00 2001 From: czlonkowski <56956555+czlonkowski@users.noreply.github.com> Date: Wed, 12 Nov 2025 17:24:30 +0100 Subject: [PATCH] fix: reduce mutation auto-flush threshold from 5 to 2 MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Lower the auto-flush threshold for workflow mutations from 5 to 2 to ensure more timely data persistence. Since mutations are less frequent than regular telemetry events, a lower threshold provides: - Faster data persistence (don't wait for 5 mutations) - Better testing experience (easier to verify with fewer operations) - Reduced risk of data loss if process exits before threshold - More responsive telemetry for low-volume mutation scenarios This complements the existing 5-second periodic flush and process exit handlers, ensuring mutations are persisted promptly. Conceived by Romuald Członkowski - https://www.aiadvisors.pl/en --- data/nodes.db | Bin 70729728 -> 70729728 bytes src/telemetry/telemetry-manager.ts | 5 +++-- 2 files changed, 3 insertions(+), 2 deletions(-) diff --git a/data/nodes.db b/data/nodes.db index b843c3bb5fe81a64dca1b2ed7b079acb03cb9b2a..1f3b6ea623af809f0988104c3249d6fb7c690641 100644 GIT binary patch delta 18850 zcmd^{d3+Of{{Ndy@0+U}f()h7gC^uYicnf8rPzy7=mFSHGLtrKnuH{!v{*xNE2qk} z#*^_@JXT!PsvrdgS66ohS6$R~MR#4-JrtBx*H!twUz4OwvFo~j?Bn;xmxr%sk~u!} zxsTU;>c)-l&e%xWdC8dGsHla$s3=oTR8;&wqGWUD?aJ56di$FDn`QmY^8RL~zd5?U zIi|lkw!b;9zd63YIibHfvA;Q~zd5CqqK5(o# z{$BZ_zRhKQMX6DWgsQ#|8gd^R7Zs(oRIBPV72dVNa?6s2vig$Jl3I3-oAcQPr_akO z*mAqq#}+vpY<1|Ec<$N+CL>9$sZ|>aG@1gPL9Be`6ZzB{wXs&MFHma=G+L!rXK2jK z&$RQI1(_E=fsQ-54uQ`6r)TX;Y+)9~ha(d>mN+n1))W|{-p)(mR3Z2bhR+xCLRiQO=0?(_A zR-;XqDc(7iXBPTH_buXl96OKA%E=xP$?ROE-6wP?+q^F4+|^F2%SpN8^>MyVZ#C!P zI_Q>&0F-Mx1y6UOGI#-d)m3aZXZ6|F3E6b-YUi9eY?&=|H*5FONr%IqozLE z*&RN?!&YvUYV z0ax~}p$POM4kPZN>q;mk1(7Mr$MwOuLO+dZVGVx{*1ux z2Rp`!uYX*}OcdSc>X?~v8kH(vr!$GmUfINC2UM>;8GTt)lzh@|W#5A2D1~g*-IvXb zqAICb(qU|DcP(ux@s^sG6?dlx#=I#^OjoeAfju7hQz(`VzL0ZPex1x@wHT~sl}fEJ84Oy5 zPHVL&EH;BpVbB?D8nfQ0)(9r5w(A6s*Y0vIbagtZXfg|QVo^ywbE$ZsEshx*xX@5O zVen+$S$U>hY8{#ay|zH78bs@`%H?XcxNQA(j6OxJP-|FfJ1SLy+PwMvg)yYDq;aJ2 zqzR-9(nQiE(qz&U(j}y+q-mr}2hLxZo_sWkvTvp{vtX54trE}W_?c|~?jvlq%VHNi zoYO8)qqVkCLw^2X7u&-Yb3NU8c_{U|?sk{6vrS-oICr;Cx{`OX%RAkih4Tt*P08|F zwy3&{?paz_%lcgHf>Vk6^71MKU#p8R$jf7?UEsiqnsWS_N{|9iNNuc zXLP}8=LZ|_Vv9QIZjZf(x)PVOfL-CG3O@7%Hb-#UTpp|7Woycp=LYZK-1c^%yI?qO zoYUoG=}<5_%h14vg7*pzzhL#v3q37Z?dJ(=l^Zq$zxVdCIW9LI&N=7-h$1}-@u!%% zIyhgqwFlXT`tCvgP_DR#v#|5T;cj2MtIKI`=UBI=M~KLuU}%m0in5~0A~r{((&!ax zl|rM; zaVIvhlyB?oR)O`n90D>UpKYfyrgq_~?69}t3QATeMqM7x%1KG|c)0G!HdcwMn5fs(FRkrZOtD8nxD< z)0j9jZyoO6&x(6)XBWBJJ3FWjQZ{l0Ec#Wcj!7ja_T5#_6h*6bI+eI_v7gEEe{fqr zyWH*Jy7(ReB~jN+ncW$xwN%zN`bFhp?dfKFs1Su7DNBdTC{#`BI8UcjXdkK>Rh>R} zr;k;!Ikhz_N^%R>Vh`6InHMOAk`A}u*G&cC?R3!CN1tx$->I8J)eVK9W^)!7l`lsS z!M0_!ha*Dql}dB5%R@CO;&v2ixvPaLjTE2e=H@nT9p|-r>~1RVEQ}>ehv01SwX##@ zQJ=0_?WAiiEvV8d*Nnl}hDPtqqrtT4z#OOgf{&V$`S-GwrG@y2OZOgPGd1xbXuccDqB{X zT#eHB!ZlhvMT7E`;o_Yduhy7`OLvBU?@qRkbJ%&bS*e4zOC6-Ay9Y;t1s!Uo97{dY zVW;cFt;aV9M~cqS9bMhL%R>DX%cF=QdznxpUEXO?bh$k3HixSV9TY}_m3VC6rmTT< zKbyms>sqc@;;B+q`1n?Lhbz=&S5wdHKC!7AH?4N6mBTkmj-J}UYNvkaVsB?V#yf;9rJU**JBzLM2yV{r5!e+{ ztqaz;;VvwAlQgb$(nwH7bse9S&pr-)&2U#0jJ|YbFao^bNNX)HV^DAZ=FO`$V$8k%aE zbqWKo74*E`WH9oEi~6OEkpl;^9@B^5kP)X-qdPK)cW!B9#s^g2Y@003nd@gNMfchU zCL^HI4onn}c5Pwi1WtB67az#W*q$LazqpB+kfq^_I+ImJL$k@Op&?9VQKe-94{_d;Aa&3men)*fb)xOnPOURJ(CpQ z)ImJ~buMC2^D3rBJoysMZnLyH4R7GINTQKitDrM0I6eKe2%O$%wsC^mW(gd#>|Y_e zDjJy77?VkruMu~yqv2M1Os$yy@+Rg$mP%zYbDUtMAdEVN&OmDyi&bw>=q!4RQEM`A zyvii*$nrBy;?88AiIM5VT@=XpzzypkcMqI@l})dXk;VKXDrRuZ*+a~cn4-P8eV3=u z60qW4F1N3WrrUb8w!P;Hjm~B2Y%vP%D$K2^`FospXA3O=YlJR4RmCbdO(`*R@=EjW ziK&KKjk-Wj|Cy9#gE}wv9;)He6~Toq<#DKQm>|9iA9b&L81Ot_| zR-m5QKm|^tu7$VSbb^Ufi&xVkVNu{f|AF|pU;;ghN z6JLDk6ZxY5ytYE>7m5pBUCpEh?tW9q$h>&9n0aw-=*6?Ix?~duV^lNb|BNZxLk+KdM<|L@Ys9#p@I%l}4@6>oppI zM|=I@W%d8A#fUSO)-#3T%T#HSb-u8-pzu-u_x;*pF3{`9oQU`*PZ8BMyO_m8v)Mvg ze@e^G{LuWiiF1eNmpS3DG;-#LzYE?R`X$X%c_FwSpbj=SH=CW!<^0sr^?bsnWUsut2cCMc<~dwgj_P|MixJvo#Z@@IMV6l1)JR|@VRVn zFU8qoZxO$C`x(>41HHK5^iC!ww<#D?PjFE;oXFsqLjGHI*w;Lh%`?-bvBhn@hM68i z1F}vXcBGeXOi(2!60UI~jJWS81#2@{x+H!wF%TGOzsw5FjI zP2l~WLz6^hrk_d38j6s#x*U#CU#| zCCcGIl+>7l@x^Ir{de&dQd?W?6w~sqkYO1bd3Qt;42RO2n;XgjT98W5{K1TfNE%OF z0nO$AeWEB_@$Tux%-E)(B+*JSbp22=h7(s1kz2vI^h#0d&6O@5u8-B>%1Cv>V;9y1 z)bj@>1lC=3NH=X{r3^jG8)|-mZ|4t8CVPE);lSj;&RP2x#iHVop?Yc-Pcv$F$p9N@ z)(sfNPyCHcY{2b%JUv*Ur+9;F;U;Qh7gcF-8C{zjP>mT-#c7Nt-H703ip`(aF>#mW z<((CG>}0Duo$WO56xy)d;Ao~Xq8}68Tenb8gJbaITo(A79P6OB6Wwf=x2N0dYqwil zDZ_^h&rw#KB~G#|>`ot6n^N#0vwn_2tG3xVtwmv0ne;S+vzciI$8!p+pcB*@gGLav z966i*U^@>kpCrRya-+j8YS7<-TNLWH$!xT?!EAJPlVKD#|5>~T@K{^vMF5{ot6Wz{ z_la8_aJ#}+gciCmB|~d&#JE_fl%kVzC~DS_pns(EiE)(mll>o z%W7%*PW{c0zbB@VyEjqX{`C$fp-82*s;rzvt1t;Rn#AhOY6YjF5!+z0smwYf<%Ur` z+*ys{E{Lh;c2EyBY#NETkX4l9-+MnTXnO=-7w72-nbP#8gffm?>7bQBIq8L$L$45| z6XflMd})rQm8YktyT#>mb>R}pnPqtg$6CnEhPBXbZ4LPeqkC+Am~4?RYN%tA-cpSI zS|-$!N{uqOx-O7b*Dx-Xp{1|Xj)FxTepf<<4mHOi&uY<7nHG>;!UhY74f?HIyRW+o z(T=FB!5TGOj=?7f-6|U1;SWTN%HGIA44br#Lnfd~t25~gP+VU%hTm76>rv>RGdY@TPy;#Kr5#(t5sy)@_Iopm`o-;Wl(TE^uL=FM=m49 zvHK^8?+yBy_{8uUQg0T|6>eiD48)$9@pWM|y?@FYJoms(W}iGuPir~qKlBQl%0^Cw z)<|zz1*@RYs?CClObmmbQw5G~czlw0EOsk1MQnaINj5g%&mNc-t5<9Cby{hPlM!G) zc=A$l{u|qvq=4qrXADklex}>ywZnVBn=T_+mGlyEP3X0wO+~)8RWOpB1IL@gD%@Z( zD0sa}V^)#hZMLe0D?1udZ7cb@JiA3f^5ppvFyG&chiOt1(n3$nC z)>`_NC8PIuiyD~A(n75x*jEW25oa@!BATa|ep3T8J3c%Ri>D5*Vx~&%_lF)Wsz0b> zSQ=Lk#HL3~OWDOVrxazao0yE`@68Y|3+!BfFiFgP0=^T*TFTWuJIO&hd8Uq8BfWqP z)GpmWEwHm}f2vF!SUYL^1aV_gJ(De-N#n`+xI^h@GQ|szuVP}S{$S+RmXNImizF!` zZsKDL>zNtiMtdByk0aBM-d_uzYL~-q?WVWxVQbgB*yHM0P91wymy_O_=4aB&54(f2 zID|51#lq^$0_nAMex~G^)`k3Fx_^0%(cWIkx4R6gQjM;&G_dx$CujRNjNCOqHDW_1 z-k@X_Y@mTndfg~}bhO&;9^))MNN^2JS${K2mS5|5(x+^=Z z_VR^GRYHA{y~@7yik0eRcH1(g(7n`c)mGq;i(gXHW$kgTE7t~g{rd0}f4Q?#Z7p4F zZ>Xcj=~Y}^Wh-C0vc1gSWpAu+ z?J8??`PWzWG;~$=l;|qkO7wJ-yP=+LYAexJwiRhBYFBhs)V6!eI#$wy9A3J?ZtXDp z_`1d3#**Szjvmf;IC?DFr9I`&VlM)=mbR|5bgV$6rASzp6x%FyD^(43HT3WjdzI5` zw=P+_j_zx3toI{zOC6TF#cs>OGH;o)xZ9#_bT^i+?6!878S1*j=a%xe<@ADta>?p2 z`x@(OS{q9js~VP<87Ozd_Z!NbOV?TISGHP8Yl-Byj6!qRt1;fE4ZuWfW# zI~*OHzmBq_&8@OJS2~b-i?b5n+xSw)I{I#-SUPx(bWKM?-TIzJibODlE9uaaL#+*IBwJOpLhP}e1uDSfU-b~n_i zyD0${$_3<#%c7CWyo>5n4^Jtls!F+9`T10Ms1O)W1&gqC|%N2wX%ZR;5s`;El;CVu?sn#@1`T`6|_Ns=8?R>;~Skd z8I>9pwP2%BX}}wV$SYb$?*k$)A$!K>cTqU4KA#)Ys$e&u5NO88)69p?wDj2B*yJKj zPQBE((06J682oB+QOu-+p|!*ck0Tsj!JIiGI-oh>FH$EXw|cWQ+uU8y6Fifi8%nY{FiH*W=0+Yc$k2Y>mAd`uwyl7S5I zjTh*v$S$sDGQ{JyEzAyafg_HQP9})yPpx87A})zekMPf=uYt8M9kz>KUmnklPg1LE zHCk+o(W#{^Ws}7N4^prL_f8!sl1I}FM2*QwrnsE0&Jd5bZ6Ohmv{5yXeDCq%9UJ^K%Er)Eqw)I;ekNADo}O)#o=t-)os1XRtNfJqp-WbZH_${X zRy)9&C|jwMSBu8_2nFXLIo{2^l{ z_{%3v55r5w;I9gfOf+@_mUytjMwneW!ArbhV=MGiN$Dz~tp%aetbf>qLl85D0$vsT z7PfvU$Ja#oNI!I0I7%?4LjDwODO^sTfxx<)4%!VwWsxdKO-WRMrDDRA=8jZvC6TEnYe7EXE-8G1tX&n z%o)n*P}-y%?}a}|--b6*{*N5k;L}laLRELDzJ#-#wh;{bu>O!2|L-pjS638wL=Z!L z#wg)O_^?tI;?{6o2?s%K2tiDaG*<0=D9doU*w<%e#`%LejS3ZxB9%>{a@BA+;W~ty z!g+u3)9777xIA$g{@KYD9u8#4NX031=^;aSZ1}y5GUNzT#3WDnk{|GdMefKZW_-(V zWT>?j@qDP7NZT*ql-qr*RLNC_kp&MWpB7+TQ+fhKHUs zBKSzp4bT1`7~#waC%o_nop7X?;wNoxzUU=7?ReJ}sCApq7iN-XlCnsbk!F#yNjaok zQXXkGDW9YuDM@okDw3L{A!$hnOHVS8j3g6@b_Ev}kmiyuC(R?xCl!(wkcvpfq=f_L z3m08*$&PJ4|LCHD^N*G!FSxNeKANeD-!Txkv0NdGm+h2w$*z=@1n%f7pRgMHjze3e zqmE2swDOVr1F(l$9rf(@Pe}G$)ZtN1;KhH`A)FB3zk%jm1IPNx3sdh|d=~NWSH$;3 zrTs4Lc-q5hd(*B;W(Qvy`_|j;7q7 za(zl?%IcJbDS0VllD|rRFZqS!N0Rp@Z%DQzmnEx`CnkND^kLE~Ne7c|N$N{#O{z*V zBuz_-PW)@)Yl%-M-jTRD(V4g+@$$r(iHQl*&n28r7)-b?;kpE0!m5PggxrMm_%Gvs zAAchL;rKoAJ%eLt_rvKpG5z^lh)<+M@GF~9`&sBSPCb5#O9`` z!=r|i8g*#kK1=zPDU`@lQPFFnOJi?NGp1#xrKG*be9Ej~#>qcQD2UU>O^a({3YlE_ zw*l6TM4lRW#a;fTEMo$r7$uE?Prc<6CLYDfi&GReD4kRs8TI6|qaHmh-6A^_=%Zi< zHhRl9Ca20##%ZUC(eAX<1F0J+%m2SL`-!RX6o=-Cj8-PTpLRVnZYKQ|)9}AU`g(gb z8v-4I<8{p^^pbGozzBZCpkzRBqzy5 za+B7QJR~p4N9rW4BXyD1le$Sgqz$C2NWG-1Nq*8sQXgp(=^D~cNd2U1Nt;PqNLxwU zNZUy}NY|0BC*45WN!mr)P1-}+OZqA4MpA%u6X|BsEu>pXw~=lq?IVe#J4knu?jqey zx`%Wx=|0l^qz6d*Ne_}9B0Wrcg!D7gqof0*$4EaX9V9(YdV=&MX@K+;>1on4q(h{` zq-RM-NQ0!Kq+_J#1`h9i-g8DaY0om*q`*^04`m0OoyXO(iPG7vgMbb;8Uy@!Xy+ZmG>DQ!JNhe9CNUxE8LwcR`2I)=GZ%L;~Z;{?6 zy+isP>0Q$AN$-))klrVKK>7pekE9PtedfF3XaM!*D^fdXJIa5*p!m=6>J3xFb^7+44_0!o0z zKq;^UCSOcz$#!hum-piXabr64zK`L zfCmJ?2DAXJfE{Q9+5rd90XP8{;0D$L9>5FufKEWFO;--b+z14Kn}C~vTYy`E z+ko4FeSiqu0o)1P1>6nX1KbPT2iy-l0PF`I1Req&1|9)^20RKJ03HK=4jcp?2c7_) z1O|YofTw|HfJ4Ax;91}ZFbEt4jsedB&jZJS6Tl0=FMt<;mw;aaF9WXtzXE;@yb7EI zP64k0zX4tc-T>YNehZui-U8kR-T{6GybJsucn>%OybpW;`~mnQ@FDOg;3MGAz{kK} zfWHEN1O5(t0(=Ub1GC&S6 zKr|2o!~$_ZJdgk+0!ctJkOHIvX+SzK1{e#B1I7arfDB+FFbS9pOaU$drUKJ|OM&SC z3(NpAftf%Sa2YTQ$OdwNTp$ma4dep~KnctNRDc@L09rr?=m7&@1WbS#C;;XHmjm;F z`9LAC04M^AfrY>#pafV9lmbhDGGHli1yBxD0F^)$Pz@{tYJlZHEwBPu3Dg1gKm*VS ztO8a8Yk(_(CZHMM01IFRct8MbKnu_c*nu{n9dH00fD>>5ZeT6o0la_@=mezN)P-;B zfo`A&*Z^Dw^a57{eqbZe2W$ea0e%AX1J?qZfi1vRU>mR<*a2JzTo2p;>;!fJyMaBx zUf`#|jX(gn3Ah=!1-KQs4Y(cH2Z+EOz@5Ndz}>(-z`ekI!2Q4jz<%IC;342);1S?w zz@xwc;4$Fmz(L?~;0fSKU;uaucp7*HI0PI9o&}BogTPVX81NkMJa8O10lWbG0(cR4 z3HT-OGVluUE8y3_tH4R%6!04G8{l=|4d6}Sx4>!OE#Ph79pHDsyTI>(_kc6N`@jdl zAAmms9|C^@J_7y>d<^^r_$%-?;P1dEz^A}j;2iK7@HucE_y_O>@FnmS@K4}t;9tNu zz_-A6zy&#Ve++$*0djx=qJbD77Kj7lfdn8CNCJ|96d)By1JZ#pz*t}$FdmoyWB?O^ zNx)=a3UCQ96_^HG3QPxBUi(Fwo{p8pZjXxHE?GomH=hIQs4@p9H;;)fhwRH zSO(Mp%Yj;81+WsR1L}bWpb=OFtOnKqR{~8yGr$2BzzXny0N8*QpcSwKZ9qHV06G9C z-~!yhTEGK%0Uyu_P&+zb*afTyx`7^G18^143tSEOfsH^PGkCsm6EjW~Lxu<=6O-MW zm>1+s`rzyIC0iyd6~9@#iMcwKIY&-g+2BUcCgvGghI|sdIy#aLM?eVZ7< zHNa1Re&AYQGq45N3Ty+m13Q50fa`%9fStfDU^lP_*bDp=xDf~dHvu;Tw*a>Sw*j{U z`v4KR1Gp2o3%DD&2e=ow54azA0N4*a2s{Kl3_Jq-40sec06Yf#95@I(4m<%o2@C*F z0Z#+Z0Ed9Xz_Y*+U=TP890Q&Mo(GNtCx91#UjQ!xF9E*HJfscW|0DlGk z2K*iP1o#v<3!DQ!13m}N1OEWN0KNpi0{#hn4g3rE2KW~E4!FQZlNTGFl7 zbgM1hYEQR1(yh*Pt1I2=PPcl}t-1HMdawQDb{V@t%}q;RTIQu?ep(i!r9UkT)3PWn zi_@|sEr+CKX*ao)74qomVQ1?{+uw3TksHK?~E}MT%=7O6KPUt^&Te-9h z9J}&hh3EQXm2(bN2u&3eGoQ_#m{*pQ)8BIC9{f+2IfsYkxI7n%WMERh=E!TUyST8?b;*kd8gSGk*ugY4c|;H#Ih0bU-aU4 z)%|zj+i{8`v+z(}h1WRKinVmzt%xS0#8_#+B-hvM$#*NN16%B{;#*_KC7XQy0y`E{ zfkoKc;$%0L_nx7uv4ItP{7V(p=*mo9Suosp+4M_UW{=FdYe$ZB?lw9zAGf#EdGz`n z;hu29XkjrHYMIKww9;8Zi}ZGddW-;e*`mmu0jvdlP~h}dqfBaBqtVVDqeWL#-AOcJB~qeZLdHql z=`*4n#Lh$xnu zxm;+T`6g9_gCV0abISyI+iIb9hRvTzZXAkr_C+n}_OBJPI~d)Wt-%RGO>D)UZ<;CVr6MM%1KV3yITXL9hP#bz*e2ou zi!>4KO&G!cxz{H}UY)8&vtP!9ik}Ul)$T1SG=gj%K~((SibAP$8jbyT-;xxsRA_Pw zD&E-6Q!?6S!%Evxj5KSW1^G4V+m*?fpfrSve%-jJ9iq5hwpr- zP@JKhpzUgp#=ElZV!ctOh}~%Z%ehsTRl)j3dpTWXR%5w^%V8XHFZOWTm91irqDdu= zqg(Oa1)}tD1~4p# z!EImSN{+I7?4{0>np>07bNXGrt1Y{yI37L#cL8cMYSkmwgYR<&~d(!Q)?{PD=)ddLllMGk>1!o$*Ri07F!{htRuXkpP-{ zE3UP;BHb1h3)>W_Tlw?pdh>!AIP3m~GZedB-x&_F$c={`AFV^<9EU=qa@Y@gjH)7* zTGPz)WA>tc7KMGRu|%l55=L`>-976>otIr)w^;zgC0V=upFg-x%+v(B-^RoJqt@Z* zoVA+UrrCVC4y#ScMDA+1T9;}V-C+N^{B>e@xm3E$%HLaCc!F8^YuJ~z85K?-;+Dk}FWHg3OqZy@5 zt?Dt$AIGwhV_|EH~{r3&55%ZcYX5E`Zf+l2J6jwqgwmz_a zD$5+?g~wW;wUu=nw;;||LMdqtn zchs59eMRPq=Nbz8G%K#=!RCzh9JoZJU;}I9!Jcg8)nbe&GfR;#^jILymd~b|j+mF3 z)mYv#&!%9&!&m(VTIOdZ^5cHO$d`G0z1$iN?&XmBFVLa!ZbK`_@h34;z(I z?Tux}rD|2d4GfFllP5$VhGxr)uG}ck-UQ_18-JxDCrX()ur64OZYCTv)^RT-Xi~iq zbcvY>8-g`UrM44eG{!IN>_Dwm)o}x`B`|ngy+We?2CKxOYvJ}V&fO*)&0Hb6ag^o- zGF^%e-bZBS#e>zjYd963qmxSck~57mv&!byuz^%4a-phshGVhgw{QVfb_H;&vjlsb zfs$k7XWdrmYGikIaRl$(S~FMf3|17VdN;RCWZUqZ(bB#&W6er8d#_IJIEPJ9 z=%F^8gEnJrrt7}os1a6PO6Jh#;nfnaz%8beH=FtFrp+SGvalb^G(Hdh=h3=bt{(P+KL?x0>y%dG03Fk_dDM&6_~3 zS7)BJrp%p6d#SFoI7>2$XkRduM}yOQ?y1=j(3K?qWkbz1*u*9%$uB#t~d!?As ziPL_-D~$=8>(=p(HaUj7Vn>&pj=NwqHQs7&6I#@4g!}{ljEDz1LPi41i?u365lZGG zN4u-fYV8Tdci>va^~+<}F0?p?Rg|_AH}Z-YYcWQq7B?EL(jM*%CAQ*DqXT!@ybe#* z-I|JuHY;s|QD%;WOW7>=Nou~K@RRg-DWbe5z>)5sZIya&TY{ag**A9d39)~B)l-Ywai_A>LP{qzFvYdB6W{>78+G14>b($W<+`x~RF0)^Lxub%5Ew>6AS z`i-IHz2{g5i<58O=`1y7oxV=NKLT-QZaC!#SFYRD=eL(TTpnYo!;$B6yWCEjW2w_^ zciWsLNsrfMZ}z&~eJy5H_Ao&WuB>?Dv!(aruf8mf@Pwm%(6K%I>t?6O<$Xv+?X+XnhFN?^fc{p zTI?v!A?2n4%cl)vl#KW2u-^XMCoWg*{U4lf6Yhb>KWmun&No+*H|5xpwzzGJZKZ9V zZTx`$0-T-!@3FIcMW*87ro8`zxgtQ|a$W|nbY(qMc2-1agBT*!VY)9fq50XH7ksZiRWEZj< zITbk#IUP9zITPta_8>Fl4RS4V9dbQ#19BsB6LK?h3vw&+8{{_R zcH|D^PUJ4+ZsZ>1UgSPx0J$G|0C^C32zeNJ1bGxWj68-sj{J7u;ftS$A5#i1TA>tW z?tko|;hFB2J$!LP2?Ez7V3 zDoGWoCc{V#sU^cn9T`DJl2K$d8AHaBaipG%Clkm-GKowkQ^-^@jZ7yekQwAeGLy_A zv&kGXm&_yc$pX?q7Lr9|F=-@A$WqcomXT(%oV1V?WF=WeR+BYkEjfvtOxBV0Mk_hP{-6Tq4WIKtI9+Duv#B5DFxwMPyCa03q z$m!$^awh2`dx$}jBt`a;G}%Y?lLO=|ayB`KoJ-ClzaZz63&=roA-RZLOfDgZNQPWW zE+dzdUy@&uUz00HKe>`zMXn~-kZZ|xlXYd4v3oyh)Ccx5(S%9r7-DkGxMlARm&ylaI(h z$Un))QcB%{b^GKP#L<48RjPbQFwWD=Q7rjV&*8ktT`AT!8`WG0zKW|KK&E}2K>lLe%K zEF_D_V$w*Kkfo%FEF;ZiIcXs)$V#$`tR`#7T5=LOnXDu0$th$5*+@2#&7_qC$QIH@ zf+R%RNe9_V!ekriBoWd@x=ED8$aWGZJtRSTiP@TVa%mUYO-?1Jk<-Z;_7H<4 zNs8uA=i@Y$o1p~awEBk+)QpEx02tG+sN(Y4ss{Ci`-4_A@`E|$N;&YJU|{K z50Qt-BjizXm^?-vC%+|6kR#-G{DC|}o+W=I&ynZJQSt)$6M2!mL|!I; zCa;jckXOlTxw{Ru26L?wbqq7j`~h?Urgoj8b-xQLs0 zNG|abAIT&6q=5KIAt@roq=XD1rKF6MlcA)7RFW!EO@@&gQcH%DIx>QcB%{b^GKP#L z<48RjPbQFwWD=Q7rjV&*8ktT`AT!8`WG0zKW{bn<{=};fSk#>FbL{(a`n}a}DxZzL zNWGDBvx>~Q-kOtReOIj?pVIN9Ala@c6S7NDMVXjgIx{o=i~7pE>>sNXWsi)=T-iV{fa{ZBr%P)z7k)nG8isb!-ku)`_&@HxdT z8&xH2F6>k>v6<3+Si@C1cT$C}D%~lakLskgN0Iq1pLnAz&O$`2|kq|m& zwZg0sp6Ljtit%_YTbxp>OziH9We>GdsIhFNrb<*k)?yV5!-F|RoL*d#U!YH`=A&|H zPK%pIx7 zc8_!0Dl71eQx;0;kOJ+2yOmX{r8gW5^x>ho`7;p(b6(j}P7~_!HrtEY-)u2Fs!Swe z*{W8Pixf4SEp0NiK$x#Kn8isI*;J)HTS+nVTEe*~D0LYP^L+D*EST<#^ahV#h4Y0a zu`SfWISzA+A;mUfo(LR8m6L4@S8ltY8J9w$Q_vWHrF=le!8Bj@zMdR1C?s5 za#ffu8dYlSP~^5Ao>;Vwl<@RdKGQ1l`^>9`C$U(Sn4H4b_&GODOm}DY@HcSIkQcpJ zZLHRHt4kZ^)Lo;F?>0G2Rm>_BD-=u?bepYK*5HYM_PlQM8r#t3g5h2i3A?Vrl*N|8 z24W1e^zpdxG2U#zJfFF^NfF)CP!2p**L~GVe?S$1E_~%wq;%U|sv5#6z=eNiamgrN z1~zOO#P?X=;cz(hdb4OwTq-+^FlKSG)xTLP+1IL| z;nB5O$L9hX0QA;jTEwSvJhgnRcOVxX0v1lB% zjsuv%36O00TQM7CezqR-^VyFQsx>rgaKhXCsz_L}(}CF^O3rs3pTW*_4$DR#8Ps-o#Nuf3DDlsv6IpnUqb%w6s|$Z!un*!u*`M z`7FL9WPY5&>|SE4`Qaos^GhbGkg09#@gwhv)iEN2$YCP+C~vbUJf$Jr1WU z&y`#1@HiZHHzo*to?M5^=0cOjBX6g3wcl=YIbANBBiHTAb>a`d$Ax{n?M}=oxSUS6 z!;|N7dGWQwX3zC{oOO10uA|&%^YLnPU|zuKI=lVa!F!oYT5@tU%SGcqtH!8|dMoIk zJ3Sz(`#7bC88)5e#hEfG?6IG3 zB)H;?|9_*v4||T^DDaPZC3~ZQ*Z0hOfncgn!-&yqzLOzs_*M3L8oJYE6BSvap+R!9 zS?0|Gm$vav0T)#yrJ+|r$BCiVf^Hob1ixOw`y~xsxx?vnSZuntz=M&$y9Z;WS!PvY zV!Jz$*p1Pg>km`=?D5b~!?XF~gGEyu!O+jct%hdm#&BzQ*zNysyk$kYausXn_+V<* ztmS_Vru>n`csGm{h{aXM2TcBf+p{>19~Z>jaW$$v9{p)}TZWzrDkX)Q;j*48$9UK+;YpP+xsMu|u(Zaqm&&r=iJFeP@ z(Qa_Cs)mCdKMarNNXL&V6)j?pPW%I7uQ@t#d6PLhacK?5Aug;O9EY$6 ziPzUK4rzKHUOCK;FkGWGJHoK7>G`#*vf~SygTy7~uxE!8o_Jh94$C-p+ZyIcRrCei z8n0fk_vbN69wWvN7PcXeg9ewHhpE!hI^Iw7gOZ>7X>Mp}Kljt-{{5=D6+eaQ%_|vq zB0J|Ab4SYuduMKBGrZ;x<0ACB3MN?59|tlG-{Ri^TDYSFW1GfqS5@RN6dmtXm^+A@ zT`hmZS2EbuvOIVL2>mOUrf2(CE{@Okuh~PWHoI5;E?x%BcCTD#1v^(RRLK!_`REdT z1+Eo#zYAT2)9233FDdY%vvm0K98M2@J5Lou~`{cRD>@r_15C zdA%NVtuDVW&+c%tcXXWp#30@6Shl0{@OX(UU?Qqn}0k!G@-w2&2KC0RvQ zlQm>5IfjVJeooG${C;OFDV|hi>*1HM zFkDfp`@i3w6ldyc5#H$@c6d)bDIQe(GM1AgKEo&FIXOxN{_8>t&u>X21xS&-Bu(~_ z{p0{Si=0i)A?K3w$S=tG*_;9~mI`lLyFy&@IZ9q2eCYNI4lwDo7=%BGqIVsUfvwIH@Be$Vf7Zj3#5qSTc^(lksE% SnMfv)$?|YZVv4-ung0RT8ADM3 diff --git a/src/telemetry/telemetry-manager.ts b/src/telemetry/telemetry-manager.ts index a19c666..deffd1b 100644 --- a/src/telemetry/telemetry-manager.ts +++ b/src/telemetry/telemetry-manager.ts @@ -166,9 +166,10 @@ export class TelemetryManager { // Queue for batch processing this.eventTracker.enqueueMutation(mutationRecord); - // Auto-flush if queue is large + // Auto-flush if queue reaches threshold + // Lower threshold (2) for mutations since they're less frequent than regular events const queueSize = this.eventTracker.getMutationQueueSize(); - if (queueSize >= 5) { // Flush after 5 mutations + if (queueSize >= 2) { await this.flushMutations(); } }