From 8efe556acc415f23c1f041cfeff3fe37f3768709 Mon Sep 17 00:00:00 2001 From: shinedday <shinedday@gmail.com> Date: Thu, 19 May 2022 14:54:53 +0200 Subject: [PATCH] Add : amas method to share metrics --- dist/iotAmak-0.0.3-py3-none-any.whl | Bin 11141 -> 11215 bytes iotAmak/amas.py | 6 ++++++ iotAmak/scheduler.py | 6 +++--- 3 files changed, 9 insertions(+), 3 deletions(-) diff --git a/dist/iotAmak-0.0.3-py3-none-any.whl b/dist/iotAmak-0.0.3-py3-none-any.whl index 4e796ec802ff8fedbc6e548e34f7f88fc97704f5..aa1e26e8b87d7839981f61ecabea378170805e4e 100644 GIT binary patch delta 3665 zcmZn-KOep!k%g}!ZF7iR`GKFwtPBiOgeK>+sMn|Yw>Ihqqy&E1pxfn}->G;(C|7Wz z$J8Z{cDVkpPX94MHS!d*N2!NTk=%Wr=SMZV^z`fUR;ao9Zr!)1qab;Cit`Gy7W1_s zZCCCXxW1lad*RmnS;?o5+6mM=y|v^CxBi)@N1wLdzv6!Pf8NTKS^JI#-#Aw=vvA=| zqmRd@WGqhdub=pr@&99+`yXdLtz??g#W`8!M5btQCd2#Mv?Xhdk4j}m#9fi;V49I% z_W9PkvxYAhC8dU6&OOU?`fO(QH0N+(S#$IKR;-#k^SoHfD-&%!F3kMs5LdOx_u6!E z7Q5HUe+)}%>L1ii%W?lShdb|+&9yc6mZq$JVjFCkfBnUVDHbmEx7G=LdZ_+sx5$~* z2l5$|qJ^eT;&62FywE*AF!ufB^H0iNoS%_io%U$Oq+1-fHfVTu-hcJLjQzCO8Y_=b zH&3UsAVI$!60AXQKB~`N`0ie0@CoJs<qZ|HdSjUv{O;vk_-@;-fSS{fPP8)yuXc1; z!}n!gY3>xOqL`<#)$0N_xKFPCT*T|Pu-|T;;04=T)5Li%B$VB8nvrv1_H5%I%{5Es zT>F!swL_$ElgC8%on2=q|N7h}d6av-)aOgD{ymSc7PX9PU6geG(L%$MmL|{NuX(%8 z^m?dFV8>KZ-GJgar!9^17X`mbIAg~ss(S8d=6t>%vECmKwD8()SU5@5a8gC**NOEJ zi9IvA1l8pp@dk06i||~rk=<vC%exadmUF*~nq95_V~dV#o_y(>jj3E0M0Ac9e4pul zHO~5eQ~1SM>1Tf}6~30uAP~THY)x#m*n-1{X1hK7@}S3h<NAd>m!8S+{&S69d-Jbi zOi`>+>9KbS#T$ZT3NM;&Ta?+|&TI45)`s21u>P{<#%;&+Zgg=u2y@Nb!D3(i<dZ^< z=%!4Km|N*WoROuvnf(Qyn_Ql&yl;G__v_G?y%XQA`gwXrjedX7nj6ZwQ77(q?3urd zvux4St;*T`<rkYG-Z(DKaWE?qw{^ZNF6C`Mt#2pWv!rd2*ZXA+C$fq7J#D&r-_`%h zjGk?}Eww!Lu4><WPF7x&60tv>HP<xz`>Ct_0c^Tk*K1yG`pmU(>z#hpL&q#n{hXET z>g>SA==h-~)~!F5_w%l|3tHz3{k~cA_v}@<7nx?dTNa+0^NDfR#5dnW8+Rr&-uGY@ z-SAZ4vT5;BeeS<`G75?7I7BTA)Fu~fR0>i5u&eg9&%*gx=@;r1#PW{UoSuLE&tcAo zo*qtNtM7Gez0N+pVrs>&=~^!r>Yu1vImh=C%hLyILN82Aw!X6D+qJ*FH}gzih3K)c zKK`AhZT*zn?)%sOr?!2&{A+Toy|nqRrpl{g{?m0M=EyeqOSr##epSf$SEk-OXRogh zV(cp4WK9WK`2GI36XwQg&d=&Ao1HZt{s;?l4t7{)8en^WRqSi45T6}wJ(t%cu|DR% zam<0Wke~C7S@r58_xK)~-Px*{nl6^|JA2Pxt?$x8XTBeJ;9IapRd@3w(M>J8F3-H% zE?;==$fr)*ux$@2pK!^Pr61!x7y5s_`i3kE+p0(XteNkdzTThHV)Q^E&}!a-`Sryf zR$q>PFXrR461^PTd-=@jC-Z;IwYL0Lpnl4hsY24$a=|^eeZJ={?0wo!{%}3|`#hH$ zzrC$oMeO4_N97_f&fKiHu|7q`yU{{YfHA00=RxkS)ark26*29ME<IwR8@1xPIoKPv ze>=bWqC<OCV*Ann=CVYcZ^k-vZ92~HsOgM;Gy7*ojYWveyf02t?#JXFrfvUF7th~W zrOAHE*XE^`!LE55C!Kt*_8@ZN<Xf@Ve`fY^318IsH#x=al**B39&z9GxbIuvum4lK z?}B==k3>p-`-!tT(N9}`uY7C2c@gJs4&GZSn?nwAMsAtO!oYBBa+Z*K{SN-E8~Wyc zTWPR?o28pAc7Z0>j-z&5Q(TU^s9aKAx#QpOa{=bBq|`sIi(hnlLi)Lwa{&vd=!yUS zabU92<5@=}joX$eJwDBPG<;>4<wo|ikxEaL1%C!+dVjM?Ki+(4kC}kw`uj6`K0hwn z7<1)&`sEn;nYJlPhqiyHXx=WZ$a}r4zI3<Ru~(s~8-H^DTX#snmh&)!j_GtWj)JAm zBB$;>eUq6y^_1DNFY{d^A0ORU+mb!4ds5`#lBbd^yPq~4I4^jtJI>~s%Z>Rw7rC~Z zAJJkuF=vKTF$b@@PI^Lfc#NH}n((1bYid4o#7Qe0JLlrT(b{9X;*-%sO-^UUR^G!? zA4b;iQkxj&AJhJ5$Ke?)Po5e74EEf&dU}Q3qW`m3KFxNL)-uVszDTlVi-C>e{1f+g zJ@|L--P)d#7kk*7Z{M>Hc2T>g^hmqw%Jy@4+CMwjc{e|rVQ~6zTEE?wgytJus)t!D zzHR$pWWAZQ<?r3<4(ENQ)8t<tt@zutvpXU8eO_Edz=`^ElU|ugu-s?WH7T9!$Th1i z`YxYARMm7n#`rX!=*Nr2F0FeJuA%pcN&1KD>pAPa^v<#D*rWEr#reX`Sx@drJa{Oc zzc=@C`j6fEOHRvlF3emY=g+Pe`@ZJy--Rs&<;&JR?#w;rRW<8#+tL4GOh3vvLVy0) zH$`iL`Gj5RGiRnRt*k#b^X0}vPW!BuzPKZhb;C3#K*jOxH-?_Jclqmt?2dn8QaW7r zPjBX<^9L48`>Lz;tI@W2MrV+O16!^7(rXq=*;lEn>6|%cS+>~r)#f#8?XTF1w^i4# zFx4p0QR%&~&srgVPgg37%3hho7YyD)70idvKmEm%I<?yCpvmd%DYAl`^?@smbGFUk z_P5Tlt5dQ+&%<q=q4D!YAD5_<$qCC~otr8)ZA#G>4=pp_e@TJCcvtUv!y|X*b1mKR zX!6G${~sqseY`iZD)RB;UrHbRW<{OIRy!f86}I^E6;Vy6Ju4lmg`c-x+Ed(dxU<0_ zPI2F=TWnlGmA*ks?^bq&F4$YvQtDJ6-lCpR&@LeAY5X%{*#h762bSiNeHRNK-uQO) zMb#YTRDQqa7^%SaH@|oOH}WcvnYYZdIU?TrpzqnRU5t}cll&(Ntz2U-T|LEQd+W5l zO#2i5EO(NYZkiMuvG<(Z)booj_gJiCJi6oX&X3Yhxce3_{p0c{&`0$|W%#Ru&mvqT zQ|ilHXItd%y^`bq;cDOm#;KS5;*}H*Dn65W(O9eSpzDIyvm187VduIX9m@|*Hdc%m zlr@p(?t7h7{(W1+6ypRVk*OXDv0ojcx|TYXo;a9(FFUCJnRx2F(@)%=?qxQe__gmW ztL639Jvs{fGv02o^9{ANDc$q+u1k$U+O^C*{}tcYFX7vt&3<3`zShGJYuMwrC+~^6 zk}n&Q-*E0xX#D5h2PY<o><Lf(VJ*udkbR~5KYQB5ph*7%S~v7VLw^?N_0F~3y<o)| z$M32yp6W>bQ#yMyxc>U7-r2w1o@W>|y*`;{u<xL=F6-jg(Xlfl{;|()&bKbN(eb@f zm45nI!jhkJYD>k^mYBQ<(>eCBEB6oI&f@=>%@g;<{NbM<wb@i$ottS(+T=K;V<1XR zc`DQ9w8?vwy*am}Z4S{ETH1VOvY?7q{pFK+vjZgB9@egBy>qxnJhoxx*%WF1ie?3w zXEU37cm8q<oNTf7R%rf%i{D>goxj~<#o<rY0#AJVni8(sZZPEbZ2Rk2JZaBst~g<S zMY)Qq+GCQ*%*$o(OgBxAo?EzYRY=*4Davg7p6*{@(8^mCq?BG`a`*0H-LtK0&pwTO zEb3an^moSZ4O=vK$~LmB(9zD<b-O6?oAc_!A5YG7?VmG6z|*}fuigEma20>XD?|58 zu5%{MQ~pFX9}EkTTWtC4a^qQD`CH5WS#=+MX(s-)bw>}A{P|m{r<7EtFM4PmRC-Uu zF>HFvregNbeS#)GPd<(Od*n!T@XOrKw+u3Uyi_a-Sn4CrbsB&7ddX|;{N#h))|xp! zUOlRr|C%M^jU@a<W#(<zD}Tw>XwB<0j|5z%yBYPpQ`4UP<$+Yw`QTS;uduGZaYFML z!?ZsK0&a)>U;kkCw@YT8ay$k-`+Z{gztjoxA3t_l>2t-ioWu9eMlB6F@&4vdCe}+j zTNHNPnB1_@U+~_UUG?r76)QijSM4bIyyC&WNjy&^Z(rM6^-eGL(!Fa76H-|(@(7*# z$fCj6zxL$)G`<aaf`5ds*2K#mUHhu6HCpA>)^z#w&S{%cI5p-fWNck8`De=sR$hZ= zny00It@f1&{m^OC`^v2J%2uDAO;t7lwI+UsDX(VP#xfax7q>Zd*T^rYe*Q6zNx$BH zD?IZrrZQ%^cTGII+*JeFP5F8=)~w!;*!+iOo!yP90RQc`3MMWRTFkJ$PQ7pglXjNq zbLB&y)iU=-Z&LSYQr~m<iplTHG(GhR>|Ix6Ow{*$-IZVUx5n$ebm_ds%eL)!^M;}4 zM|<_Pl$$l~bL--@7=HDv>Ro)5&nqy@_1<gYq9<!FTeY%w?i0T8YQwzN>jCwqfwx&j z_Z-Y>P5bikuJH56m7Zs_*<)PyL?8DnJAcbLvtv^)yZa%-hJOaK8y_0}TmL2Qo<%k1 z;eCHu0=yZSL>MN^i;GQGP|rv2CCyd$WqQszc^{|5WEKrA#(R_XHDncTA=m1{3=AR+ z2(YbjhS21EA+gC#8d{9Wlh<mvGR+pBoG&gnSx8fh@#|z;O%JARQj@!+<R?dK@=V?; zEy4}cysh!`<cpdfOa^k3rL{B^K-uo>R(FLi1_p-B3=9kkFm((J4BHxKDNWv}B{jKL zOGF-|@XqeljWG-i3?M9vqA+Rl1}z;>R=%et!}xRZ1}*8y&y{&~Al?SKoPz;m062p) cF)&<XVPKF$GGGg%n+n*bOl>hXKXs4{0PYFYw*UYD delta 3534 zcmX>f-Wt9kk%jME(#DXPTsQpXSQ!}R3Qo>vQLlfu)?fo`mrj@5HrI_Wbvaq0q@rC^ z0##R9<X!xKPtq>MbJ}NyAX%YqnR7Lt3*)*Lz4-L#d0Team6+G3yF0|Td71TOA9lIy znHr(XqY?M~!-4Gm*?e;|${io9zMz&G?~<seuc!ZKk==`j<;Q(PyLsO}Dso#tGs9Fv zxZY=`nbx;@p_}qQ?9Y8(yF&52@RX1Xvs4yNzP4ck+sAw9Zl|n*FL*Fl26BsVCG5L- zRD1Wf5)X0FDYa+KO<R<&A76S@c-O3(JNEs%D(P`EG+1cIY3|bs%0`bT?)#!KdyT%n zgx$2{UxsRRHwx^%Z)~y=Uu#e)m%U=U=538iel794vpBqGIxnez8-2*`&yl+6x)s7- zdK^-ohb+}m5(pG}b16B*zTnr)yFEX9T(>a`yHCBc>?yB{=czwI{o5_8-d<R}Hzak6 zN{+Uuu+Nss4qdkYp5*0JD`fLkvScw$E8DDT%25?DgY#A0Vs2G40e3qdhqZ2u8*hEC zez9Al^wF1T-|wzGC?@BtSAWXX%2lS;M(~04CtZE1DGT51IB2j_+3dZaOKP^Q=pM29 zV&xQR^>o!w3&Ia>T5&)BfJR`&<tfvzeY5|6YxRkjS|a)70{wG6{T5p8+q~}n6{qmR zBZgsNdlXJrc3y0=aXo%x;fz`)t<0FN%Zjouc20WByv6Lxg?6uLXFQ&nUSm(IpUP+~ zYOq}HF>f%(_XR0;Zt!M!t8LFY^-{8U?%BP{HF4AUw)b0Aym3&R#Z<&qKEE>N?Uu)4 zk*fLgN?%Xkw{?x8gUd~(i2Y^)3m$iu_db4i&$8TR-!Y>Tvx7~(Ot0CR$3MH`WGUyX zCp(&TFP#47pkJG;J!@M<!jUcM6`UPRmsi)9<<7NztS#x_y`;j8)3)sNQ^yFcl*<Ks zww%|=O1)aX#`?k8?K)PXmHkHBFN$CI?pC(?nSS!8xi%-tSo`<9G^khpR_7<Y&PDsR z`!(6T#l~4H*?l)P_HDfVLh|Lp3lTq8mYp&!nZD_4kiBZsGG5g=CynFk#cczVjqa67 zd@~fAS${*`%dh*|iXS%@Pg~=<KYU$Xi&4hXTHl%CbHX*&KFwPtDDD@icU@++6tj^A zN7wY%Muy)q=Uk8N*Zni&#`$Nj^VfY#@ZX%dkT?9<4E`HEDf?GToMTNtC!M*0sf;Ok z7hCwRO&8uTV-$MU6)^Ge$rLfYu+~@6yYlW^1;1H-%hIH)zIFD?ouB)+|2Zu9FwpZ* z*y@9wTer7Q|DpNulfJ2ugZ<*)ORL^ZQde=Wo_nZI=JrCht=r$_pDA1Ixm?QW!t`GU zG|w8Un%f*@TVm>Edw+8b@BQ!#yUw{J&uwBl!hE&Z<lr3_-_-K--iR4KH>$5Mo3ht( z@$KKmpF`ihi}29p=V^aj@2p!nb85f|A>j??xB2Za9dIpenbrHoCDFfCxGc4iZTjv1 z`odG}&h^dvSm<_p_k+LY%NO!kL`?B>Klz-)^LS0oeix4oD;>U@Zv7hm(tcif30GE{ z-_+S{u9CKvEAO@xmmfa(bfs2LhyJRh`mh_#e<ikxm-;fZ+c;gEJvlRT#<u#&#f=uT zrw9ZUYJ5=6Ww!p<RuQw()#X5USETTISC_dT*8Z$CmD0JYpJOVMeZcHYd)<u3oAnP* z4mN9Xi_N{{{#~@rc5|4NI$M9mX6Zi@V*6X!bgT7zY_!)~9G)way7_o-Q@2+7+1=|t zKXwpwYxex3ezIv=WQT6&o_EZuHt%bsf<Ju!>EyR;hQ^6|d=sVP%uZ>3e|)+=z?+$6 zvVexvW>&7b9K2`UHirm36&IMs!oYA~@_Hfl`YrrZH}uW@w$fk&Ym;lU-USiXOG)yq zUW<~Hgq}_ciTPif?q>dKm*1nc@rzDRNIw^IF5sh0{@$t{ekD!gg^_a#lOwc@H^x=| z(7Nh+?u{e&JddwOQtEWJr1mR4KkmHHHCdtf;vVCf0>{5*?ag|3e%W5TqUsYVE%^^W zisf$)l3ZB7wtjcwv8?^uZv5k{|7+mlf5?ErTXzaCQ;cWFrVZtm_4jTqI<alpr}^%Y zua72w=eWKmTy*oamG323et+#c*w69!sDhld+FSm%mrUEu&xr9%U^QMUCLndN;@m;D z^(|G2F{(Z3kzb#2?lE)dnLjf`fJ@Xm;A*N;kXT!gr*zvs!TQKui4*nawemeJ>^J1R zaaR9Lzf))J<|7{k|K2~Rd*5LF(nqX!qfDA7OmkCtBmCQY`k}is@2&D^e_|_fhwt7@ zBcqMeCVsG8vQK&UTp{)RV96=RTcQQGRr4%#mp&3ErsdP{IDuPzGxuzV8~69N+dQ#O zKDsfo=lXqv<s4?;N<R0p)-QdfyE4By@PlT?!pvDbK^M&C)LS2V@gjB?OHHJ~+n)X? zt=HA@3wB7bniX_Uo3q|q@0`kxJ&7M&oG<)rdwNLX!9%h9&AGSJf9%#5P3=2+!6cx6 zd2_%O>-f6r6$&rTnUvaWJ{#hBzWCm!AM=Bl?#nH-lD|Jai1!m)(03c-(`&ZWpI|X( z4vRPuzFcH(w3F`cX}n!3EAA>YELQw`w%bK#<DP~SJLc~9UUr1rAS0!=y{qnlK2zGF zNo*4w??)~*UGl}@>yf3cH+LM#+vFZQt+|i;uzUHEtrGV_9HM5{mRs0ae?2A1QDu7I z0^>ZD4{UDoslRw!r&`AqpZ(01dOqb)*OYpm+q%=5F89vrpMRsDdvVjTp5u0x92dGZ zf3rwu_21UnvG7RE`YkWdo{tk~n7O_CyrIjTxtvqCJes_6#eZMHwUO^5H?R0wP%K!Y z?<xDh^s=*S*Hn*rL5)gBW_J}E<cgjC)c4`oW`@K$N;RQNd$%n9Hgjp~vdJRr9oc(1 zUN2eq@?8Ca2YiZI6Q8|W>E$r}%z?r@Gl|K~O*i;TUsTOmd`QltR-<!;!?(Y8>Sryn z*7f<k#BtgBxevA_WuI-BX|#E{&rGc~)}riFwrp4$*8FK-!iVKS($Y;`u@QSy`d6i2 z%sl6j=Ai$sAn6a+&!*-KRojUblZrW&-fNlOkUOo>eCAi2bp7(VlV{!K+-L4(Gpp*I z;Xh_ZBboRo2N>QkGlwtH3+a1nobDRe!?jC%-W>0*T`v~=3@KRA{qkKd<H|4fW+GcX z5@LBBth%N;eLZoI{a$uZ|1<H_xD`+SpQ`51QhRMXo4aV8cWI=9oWbqP;=WbY74H&W z@9O-Ka7H(C&u>oup!WFsEsGhyY!%}>UiBr``sixszqg!Ak3Cn4`zyO&UY0}cAbV)r z{>zR`8^iV<*`FXL>S`viLF!v^Y^a{h(v92G<wd4izSz&QH^${~{1VoBxpz^!3ybf+ znj`M>z-p7EPyUAs9tWTN@(WL!_W#`U2fNSB<@1)_dT{3^(-|3do7SK2o+mE+MO*A~ z#Zj}m_B$8<-$+=pKKwu91gXun;_BQ?oF0>xDIEh*dCF5k6sw9iC#T2ekOfNSw@*!u zRMD!xbaK+H0ExDTwd+{VBu;Y`Q&_CDpovSGYt~_#;(#ZwCcpA3zdhG0Y-i*0d;9m< z=T8i1fBIeF#B3SXgR80&lEo(R{BC}x^7Dddwy#ZV#e)}LS<|;kTgX1xxJI)0ey;vL zuhiw9g@zw=|MRwL=3JO86#01Z%XfTxujkyD6*JG&FR(sjS9@9iUNcp5agT;mn?7Aj z67k(AA0XT3?^ncs<YUXBr*;g^7Fl;&O?}k;XT6F#-|AcWv#|C{qU;tqH{*u-@`U2k z?b}w`r*E{l`)tuZf$M=0$2XVF-NbQn>5i{bD|h8|DXjK(vb@n;c${O_pA)Ax|LW{4 zZ@V<R?Y=>#kC%!?eIZMPUZ?4Iua`XSYfn6k-Sxe|NYilIlI!o!{FrpGV%38WEvbvw zXPmKgtysbM=argQ&z3~PpHoCRTm<C;G%l@O=_qW#W+3moB6s!w?GILeyJY4m$79fA zulk9(Hs;9W+ZK^2JH*f3scMg0J%y{%);fNngH)@SOL(!6!ME(hyUO(<dqRFbSM4bI zyyC&eN!w1`d>3`Q{EhRjC3{yoC(ajjG4`<7uI9jbO~SwKq)ftHr6206D(6{sSzmp} zwc8_Pf4aPQ=d?{JoEmc#GPbUl{Ill-E3d(`%xU3YzMCb698~{gvugL1pvsvNsaI_S zYfbzNQ(n!ojb}FeE@pG+t&yKkfBi9zNxzDITcp*8?W);zq};AxMcc~>m75Q4`QFMa z{UrTCb;5H8+q;>EL%Y0snC|@cf1JP?c17!)d&_g*OLg~8_bG7peP9c|{ATIQjdL93 zG=hpRt@&{6^}L5)K3ne1zf##ZtLl8JICsJk`#argr;kZzeLWt;cp*6?SLXZM1tOtO z{9f2TI1#<Pl#5&Fufm3_o%37co&R2S$rTUzz_wa+*2USj{&U)&tD1fm`{26gakBRA z^tUVTbZzQn*GtT8{AZxEF*5n}{!8wa$+D_EzrP7j_EYah@7X+8_hno(*;K=sapvSo z4Ow}V8eEuxL4*MTwlxM%-m2lqBrQI<UR-Ljkfs)6@MK#}Po}jJlLaMZCok31V$7R- zLDP$Awe)0u8QIB}T3SpmWGDN`$?yeuGct*QP2*tT^qAbQCBqb?G`UV$YVrjoj>+e> zct9EOu9ggwl=9>{W%<cc+F%h4Z5gJGAQ7p_3EGkh@Z8D7z;KO)fk6)8IEF2Z{~!uC LYm2e5sDoqxJk)%J diff --git a/iotAmak/amas.py b/iotAmak/amas.py index 89a8312..f43df41 100644 --- a/iotAmak/amas.py +++ b/iotAmak/amas.py @@ -83,6 +83,12 @@ class Amas(Schedulable, SSHClient): ) print("Amas, push agent done") + def agent_neighbour(self, id_agent1: int, id_agent2: int) -> None: + """ + share the metric of agent 2 to agent 1 + """ + self.publish("amas/agent/" + str(id_agent1) + "/neighbor", self.agents_metric[id_agent2]) + def agent_log(self, client, userdata, message) -> None: """ Called when the amas receive a log from any agent, print it in stdout diff --git a/iotAmak/scheduler.py b/iotAmak/scheduler.py index 1320311..600b910 100644 --- a/iotAmak/scheduler.py +++ b/iotAmak/scheduler.py @@ -61,7 +61,7 @@ class Scheduler(Schedulable): Function called whenever the amas/env have finished an action and is waiting """ self.schedulable_semaphore.release() - print("__Schedulable is waiting") + # print("__Schedulable is waiting") def update_nbr_agent(self, client, userdata, message) -> None: """ @@ -70,14 +70,14 @@ class Scheduler(Schedulable): """ self.nbr_agent += 1 self.subscribe("agent/" + str(message.payload.decode("utf-8")) + "/cycle_done", self.agent_done) - print("__Update agent : ", self.nbr_agent, str(message.payload.decode("utf-8"))) + # print("__Update agent : ", self.nbr_agent, str(message.payload.decode("utf-8"))) def agent_done(self, client, userdata, message) -> None: """ Called whenever an agent have done an action and is waiting """ self.agent_semaphore.release() - print("__Agent done") + # print("__Agent done") def wait_agent(self) -> None: """ -- GitLab