From 33591ca8824ec3ca1b3163a7823dc5f3096fc974 Mon Sep 17 00:00:00 2001 From: hhhhsc <1710496817@qq.com> Date: Tue, 27 Jan 2026 19:55:29 +0800 Subject: [PATCH 1/4] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=20VERSION=20=E5=8F=82?= =?UTF-8?q?=E6=95=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- deployment/docker/datamate/docker-compose.yml | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/deployment/docker/datamate/docker-compose.yml b/deployment/docker/datamate/docker-compose.yml index 68085ec6..9f3ec006 100644 --- a/deployment/docker/datamate/docker-compose.yml +++ b/deployment/docker/datamate/docker-compose.yml @@ -5,7 +5,7 @@ services: datamate-backend: container_name: datamate-backend - image: ${REGISTRY:-}datamate-backend + image: ${REGISTRY:-}datamate-backend:${VERSION:-latest} restart: on-failure privileged: true environment: @@ -23,7 +23,7 @@ services: datamate-backend-python: container_name: datamate-backend-python - image: ${REGISTRY:-}datamate-backend-python + image: ${REGISTRY:-}datamate-backend-python:${VERSION:-latest} restart: on-failure privileged: true environment: @@ -41,7 +41,7 @@ services: datamate-gateway: container_name: datamate-gateway - image: ${REGISTRY:-}datamate-gateway + image: ${REGISTRY:-}datamate-gateway:${VERSION:-latest} restart: on-failure privileged: true ports: @@ -53,7 +53,7 @@ services: datamate-frontend: container_name: datamate-frontend - image: ${REGISTRY:-}datamate-frontend + image: ${REGISTRY:-}datamate-frontend:${VERSION:-latest} restart: on-failure ports: - "30000:3000" @@ -66,7 +66,7 @@ services: datamate-database: container_name: datamate-database - image: ${REGISTRY:-}datamate-database + image: ${REGISTRY:-}datamate-database:${VERSION:-latest} restart: on-failure environment: - POSTGRES_USER=postgres @@ -80,7 +80,7 @@ services: datamate-runtime: container_name: datamate-runtime - image: ${REGISTRY:-}datamate-runtime + image: ${REGISTRY:-}datamate-runtime:${VERSION:-latest} restart: on-failure environment: RAY_DEDUP_LOGS: "0" From 9f1ae0f393565e213e74094fb7654fdc58997c57 Mon Sep 17 00:00:00 2001 From: hhhhsc <1710496817@qq.com> Date: Tue, 27 Jan 2026 21:00:01 +0800 Subject: [PATCH 2/4] =?UTF-8?q?=E4=BF=AE=E6=94=B9cpu=E5=92=8Cmemory?= =?UTF-8?q?=E9=BB=98=E8=AE=A4=E5=80=BC?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../ops/examples/test_operator/metadata.yml | 4 ++-- .../examples/test_operator/test_operator.tar | Bin 17920 -> 5077 bytes 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/runtime/ops/examples/test_operator/metadata.yml b/runtime/ops/examples/test_operator/metadata.yml index feadc9c3..2320c9ed 100644 --- a/runtime/ops/examples/test_operator/metadata.yml +++ b/runtime/ops/examples/test_operator/metadata.yml @@ -20,8 +20,8 @@ metrics: - name: '吞吐量' metric: '20 images/sec' runtime: - memory: 10MB - cpu: 1000m + memory: 10485760 + cpu: 0.05 gpu: 0.1 npu: 0.1 settings: diff --git a/runtime/ops/examples/test_operator/test_operator.tar b/runtime/ops/examples/test_operator/test_operator.tar index 1ab13c115da1a9c7faf4cc6dd741bfeae00644b6..dc986c1dbf138f28937464c5d57341de1a983a49 100644 GIT binary patch literal 5077 zcmV;`6DsTRH%U?UiF`1cSe7Ck0iNPPHh9A;!3&EGIAAb~Wm9ZI@-i>;Hm@^3AXj}P)jUu& z&-Y=z?yt|HV|n9ZlMCv?WuJ5U`}*r|@9wX0HXJ)t|H+X<&QMduRyCK)<*%tB?02o- z$A7y#`0T>Jy~OQvdwsPokE_;8Ty9TIZA}GnZ5c(D7LTcN6i7K03#{1>x}7|^#&?_w zF@FEGw7>a>k19T_s5l}A$d|{-ABkw}UB%zQj|YB!f*)0gfuG;m zx_n^1|9v1Fa>|iNi{gw#!>5&2xiz3veDGn#M`Pi{@BXFvzu&+l%WbuGR6hHeA~z|~ zJzM7o*0q1P%Vz&I9*?JjoPFbzlxXj{{d-*`qy|IEes`^ZUrmk6>-IUlKKH)by?%eK zWW%mn3cCkv7(?P2JYUXXwOCHkB5=5}n%6aCYf>HkF{$H1u z%w_Gy1*Afffck9efkC~MP}<-5YN6+-9QaXgR$eXi()0+tqQeh?v}~$RyOpBL=Ycob z%ySqdKldUxmCP1oIm}7!}+Oxtv6AaNH94*dX!D|YGW_S(Khu|xRqp=CiBn6 z0O^Q8YB)bqL{$+|dhsTxUViSWc4ZKafD22KcJJQJmCEBJ21~N3L7Y0Nw6d}aK&;P= z1o@Rs>sB!_V^!Z@6BGF~sMzAKiAmrx?H$NHoYSr>#nG2v|%tCNrTjGQAlJ+fXqM}UItQXe@7z%YMu zZubV7=n5c>t#U|dWN1*}d`4g*xqI{LjH^BC%g>D>7@}%YVu5Hdq6WjQ7K}qf`Q^27 zF>LwetJ;-0VfGfxz%oSMBDXfj!TL4 zb!^30;yp(jmCrN;n;6pSYTEgvFp@+GR97>6%bkU(3}_H(G_9qPphn~#XP7HVf@OpI zP2{_u0+O$kn0f@VDkX~OPb<-wUUH7D!PX> z23sR>HOBu8$5s3rWWnbPM4`@WGgDfkom4XSwI>*2K1+@_1;cwz2b+{|701rL0dk>^ z9>G(jO}qY78=Ke0r|I%Isf;QuiX2nGVv2$i=QZ}vFP+b(E?Qw}S0_!r)ZJ*C9BPpS znmUP)-NaG2JElFFV(vV3-hr=h5?~gLJ3M}9mj|+o6Amf&0uS&KJ{;m>KOMB@~Xf)e*Pr$N}b? z*i2`ypnb#VKqSt-xm+P8#GT~e(XWXJNu%@Ng20RBr)IRdhw!or`Zu%wE^r3~`~NHS zrvp>a89uh!K7L{S7=w@mk`5x=2#UVgP?`ZQ;+|cgpfwPQ=@Q<%qaCd2eT0~R~nhodR~CrM&Fzp?JrFJA{;YL zoeMsjzLQP=jH7{!MeOIQhY19;>l=Nq7OqKBH8_RiEnqWIQmJJw(Tg+MdN7>vg>LvSA>{o_%?X*-0l`Ru_cMTp8=MfR{!IShv%-lCxDwq_{-1T&1JfZ!g9|TO(p5Y`z$_BJc4o5wg{sb+2SyilFI>E z&WSlG$6M5IVCk)ZQK zC<+(~Y|sF_xGvzGdk7d)l?a+Q0BW<-h0$dIoErkasP&BjIGgA%H^3T6B}907w}W>^ z4+0r&ZuBaPmx}{H3J48Yp?`$2;6)W$A6MctK{arSR5IJ?d}7sLaKChZ1PIaw?=cT% zs4s^=^<7inHljin@pH5eo2VUXG_E*I3xS+iyD&r;AX!RAwp3X_P7nw>#I+ zcnr}5#J4vt9Ubv%*0D?1BGkh>V8ahU1Hq&ViE(gSw5O|ZZRB+-n7 zu3xNhAPD!~gLObQ1xdqYNCAz6lI>As?rFWtxHM;3$;;=6+`6lUgBojj>-L!>xt+jN z6U*ZaTS#6LIZ6f=l5E2vB&&)u5RNL&A7Dk)5RNnw1R;&Mcx+@2xbf3qiwb|UkvtqN zUvc7E6Y_YDS?r^T#VE$d)FAVGnOS1n;lOpPx#nfNVvzN6d~6Ue8|2VgB@kB?qK&|t!&4R9sIXY5GyNrs!_PVK%dOx)*;Lomm4g~VNzzU`HQeg!p9kV zgs|diIk}5e%hBc-{Hp%(4EsyazNMs++mdjH60{U?2N$zI8s?vtOCMjga)9U z)Ny_O9{O{gJ^}0Ck8Q6^)zFoSHFSMeUu1l$LlX4?(4U*zLbqOklLy6xg(Xd;aMzq~ z1U3Aqw2|CwFD|l8bWuf(N5P$2?bnK{Bz-%@mLzx%T(V+t;m+VXbG*w*ZRDk;J93wA zNbMK2fA3(AjuVz%!ka5ide5eCLo5s)?i9F)N)tzw1*RAoz!W1fdK!P=gaw>!SGmSn zw4o32#Vgy_U?Rg$$HQsb_wh!I^qZll4ogEPFLdomdVon4trE_?6US@jM~2= z9EmyOF(vA>kLeU-?U1T$dggPAoC2AbP4}@?6J{28UXn{rfjMGqzT2VQm=GJ{{9|GA zhFB7(FM|YFgo?#YvDc$uk{8g1JhklEe?dMf68+LvkP0IYPi$tjUmA^y1qme-8J z^5H=?18An`)B9Tbypfq;XWT0?$ylMyVmDCV=+d|II3qA35==@kVgg0ncjzyf|88wY zCb0qZgDS47Y$?l464v#QEuw&Mg#6+oZQvKK+PWb9hQsK+49*tvGFTbGa#WIpOGx&! zGt=Qg#uc`s)TQ+%w259ks?>qfxOk?6eYu7E@J2XMjtPbX@i0F=pr2JtYqu7};Vrrn zZhPoZs;f;u!?71-t>T0fh#EE0OJh{F&5dawMvWq0x63AmUB%h~E+uz8MLVCMf|`28 zGb$sW1sN5(2l98@f%(OQv#5i_4G%!CY-#{VV9{tH!481UQ<@?N48r0kC%Q3$uLSmj z+e%&ogq&|^_ka~F%a#mtE@2?UElrRb_b2QeoGG4tEJh^fII0S$8~78xjchu$&3G3x ztrUJ`Cp#o7boUd(r-a%X0`Zs{4uJ>M{fX|-9oCNy!U_Z|^IgMHl|pJdDcW-t7{IK{ z&1d#;M9tz=|O-fA2OR1d+0Mc{9y6zGm+r zX6?oW@GamSAeGVMNZuDDFOB0mUcvMOghb9B*wp6pe;)1@*S8IyT-Q|2I`@ zi^kY|{jb;S@t5m=wxyNpf8Xn7*8gsuAJ}~Tug~SHDcApQM=M?b>v8)$e!s6=|NG9j zt&jfe+rQW4vB!V6t6cxPEp4^kkIij=tiIG(dzDeTm0l{S0NkK&Y#3{Ws7|x_l_! ze^ycP_hxPok^@2o|6H-g+Td?1hX3O~|Lgky)c?Ncr|19p=T8Rqyx!Cy|LA)W?mh9p z|Cf3_1n)pI^Z%{$1MAtp&+oU{zt7|Im-GMaXhr$I&s|$vyVvRV*1A2l?!BAL|AVzn zr-R>kqkE&x8_xfA`;**W?^;7K&#?bs{lPz+Ir7INp?%*S`1IRTXVp{xw)fa!*XjB< z)Fj9{S0kGf@TMHkZzyNk`slx|{nym^J@)wTb(Q1)wlq;?WxWOCkcz9T*0?R>ko21} z&<~Ft91@s!Q#cAQPQ~RjO3)$UX)nC6 zw}8)L{jp{&W(C^_l(@}e0ow@FUvQ~Jzag=S+YHv8qWt0}P2aV3_JRM7A=$+s{H6$= zAKF0Np1ns76nEa(O^lKkQ)>45YW*(#G73o2XSrx%xmF_Sw<{R9^}YfhQdh&wrQCyY zR5FJsXjxko5rV5C>t0;=ub0GF%lvVMX4xkeeeyqz8hJ)xaY?#aj>wDJH%6hg?+OZy z+VoP@=@OQQ*vmCns~_i|)+iHaC5}e1Q}J|o4fqD9W9e(3j#0k7N&)w(6Dq1eU84qd zl`7OV>QGBmqVfVOYcadQ2P}%$rn)x93S0LT!o}M5-#$Bv%gGIHU}g2jSRwkZ#tNgf zd}VQY$?|f8+SN>ew^5XIhYoo2ZT?E$p z@pUT5e=B-fTnTRKB`-1DFkful?R+r`!);7qSqeF9ezfu9ZD(w6wmBQj;+d@)<2BCz zJvHV1|Ltkz^Z)m{nfrfR=Lgocf3g2>J^y#P%lm)Z(LDP~p8xx6yncWA`2XE+TOa+` zwSSM-U1N{`poiu7za4Gut8bgQ`z9{GnOl5YeeG@YSKh4mhQxpB&_8Be&BrD#H8IFK z`%6Sv8ejQ3-8*!hu6&j5H-43_^cA|d?Mwd}o3p`wDeKLTvHA6Xjn7q%|J&2b>;Lz< znd|?p^8@SJ|BCv5zsFNsUjJ`LD_#FzHofzu*0~_0fNQ`*(Tm_5U>2DKRw&!!C{0~<|^AapD&IUb5wA9l>KeaU7jhICmwNUI%3a~nkJ$AX9Jn_K+ zvXPZ03xp&PwuB{i5Sy``VGk>Px z_Um#?hZ2pT8GrtN%B1W|NaASkm@uMe20_KI22g8w= zHy$&hUK6vi0V5hP!%=S}8tyh?v4e*i8(c@)|N0&r2pML8WbEw^^}ffn_Zqs3{dXK| zYvuTVti7|NvxDrv?fAa^zZZ``bTAp^3DIo58Y`w|3(0x8KHc2d&|}29qrr$74ENz? zar>5aGnG##^64k;f&WZg#@OCK-}!jpJW+}Cn-{`;xb}n5*AtH7%7u8~MsRLzAHIM}r}(aWoL`35JjU5bQC+M?>*m zGpNQlHU#@3aWm$gx2I|0xLGxCPt&4CuK`bZg8bJJ(Oh~oXFXeyQ`cqs3XY(zSu-hX zd_dmGSc}i(gR6z18=RT^gRM9^2-F z_lGEAM`K1eZbsvMkOK1}WQ4-e{u83r_thVW58aVC{qXrh^y@tR@_Ae7JH(~G#|+a% z>|u7qdLh~9=|D6PQtZJ%t)JQJg(vf@e0oQ_>8Pcqu#S=mZb#^Lq2|4&;k2`e_uHC6xqRvj6&1l@v z*P~p&!LrT;dSeFfwEKe5{k_rir@(gx*-|MnnoqCm3Gu$qEALv1Ph10{0T@`lV@=Fr z)LxI}8eDTMwL-m9g_XZ)eb>Qw2WJud&RAM`Yfq+oKLmQ?B=AbIwR76^g0*w_ zP7KE0ZPsB)K0RiQjan;1d*n*h_!`FWLjOjbiNf<6br@3|zanqH+#^@?V4I6ITv3Z? zrXb%#>SqQGw+3hrp~n5mIA^-VsZCx5hp*$I?~rq{fsm|w49E82qnsOV`=@~+tSXA7)AqOAsokdmSYgnY#smCA6f5exRuIRf}tohJH z?gQuP66#}?|Ek~jj{3i?{a8)@?`!SYum3+#r0+FNm-+CNNW$#8{*S?K^RW1=uYYfC z050cgY-2-rZy**EPLkikHxKD_?%=_L>_oZLC_K-~=?R(56q89#O-qk+^2LU{zKQGB zi&>dm$iE%^B{!bm8k3JMy9hHGMUTJ2p9{O2)q+@h?y&F#qUU4yx!IMjHXjyWP^wrn zTje?RXFDknW;ZuiPgN;h-I-20xx++c5Ian?a|=xT)`tV1tzOlRLUrfcHR9zvasQtb3S_K}JuP9@-P`iiJ@DUw}_)afrASps9)+ z=vPv)Wktrp=hZXb%RBz(4?c71vp;@y${XtWh)1Q=dFS}w*4o6gn$BMX?Yaqp3->dPU)O zQf|%`vNx>dt9($pr~8}s3EZ27Q~f13ayrocJsMxX)m zHTgUt-#nC)V3D(g8yMgfYL}3MSD63*Obq<>OTpO_E0dhMR(y5U%1oCACkmTMH)W^f z&~)oL6=PBhZgklr&6eL?c*1>rxBB^(L`x60evVudzMd+T61s3 zY1O0_`K_hmt2v@NqnTQEh2?Fj6IW1`*X}?Ki>a5^%}F*0QXL45{v0`?a5E@bn^%;1 zlTS}F4@8Tbrz)H9yRY~Kvo4>}GJ>J8p0G;)oLDSop60WgKPQ&Ja5*|rc$%_qZXqg@ z!Ye)(vR9#mWHsPFb720p7Q`*s3+X2t0&TKYpg~<&N#wUztbvp*sm6v&f^!CON$^n} zj_mO5lFkjpC7KOJh)eiy*N+}bbNtjn@nc1;pXyvF0t%}eJFLlqvZ^uQh&Ue^+|U{7+KQDJ5H0m# zoI_aXlFCnCygduu#JLS?{-NBS7cClnQ3g~IxfIKJMse#(K7GwSTLS+` zzID88e<0Kg^a7R5ha)-K?(HpC860GVXoir8Ei*_W{!8OJv6{`7=aLfHjHUHSI{6KLbRFnoAUBn;c=!k|B{3a_otvR zo=w}))~}AthvkFQTIDXQ+$%Wcp0gXkRw2xG9n6Z!EkrMYGLKOzlym}-j@_)2J8%*s z{Pr-oa#eJZ-Euya802iGoERYf;lR*oBrSz!k8nQ68IdnyMif(sKh#O#IuR=>RbeQP@5tw~ zh+FL670wIMD;B_Pbxh0NVjj`5iW-(J-MdMoT>c#hkDH>UoIFtkLB--y?k*-;m!HXj zMewv7FpH^2h3rs8Kp&Zt>7=~&m?Hb)Gg_z;G-RfLu!^$GdESoG07qj+4YO5QUb|b| z++<0$a^)#4&M*Pp zL<)#(6sCSwl!Y$`2a3rwiyDly787z~N(+R6jq=QEyUu*Ds%Ms=P+HSke^{E`#+s=q zz~I){9Mq0vc5fN!w`kFwI{?3eeG4+KxS8K?=^Vc&#C;sP9xHb+& zkY$l!ly~ZGcFNo=BCjX;IwW*IlV>I z9Qzdor6@N;MZsaw?BLE7Vzc34b>LF=W-#`P|)7;wR`9v=jBN2CL-YYe_=f?KsfwJlC}8V@xntZ&h5`cwnhxCBpJxi=nLP2EP_s%g-5m+;OIek)oy z8pv@9$`F`KHdO%cuO}J@)J6EHgmlY6-T`#g!FiYL-)s)O1K)Ma*oE#^Vyd;sZUwGe zxfMorNe1>-$YH+cR@?~hp7-Js+2{1^20&goLxt&9%B!O3{VQ9OOpo!YM~X#@3qQk$e)8b{FM_>zs@ShqLx%-)6@17AFRCO(TDN!j zmJYV*NphRnby3xC;o@183vcS#jSnzAwF=nl@tk6)N1%Cx@a)>Z=C)sBL4G{~@xq#X zXwAGvJ)m$QKdg0qUJj-Y2?dtS$lJ?q?1gW-n8+P33w86-HZc)m=SIP9XzlKgY&%#j zBej1I$D`lq=c&I&g8qMj*TO*vHeC3TaxZgt%yu7A1rE%4j16nn!(#uvAk|7`*oRgB z)nQeV7k%uAOyQj1WDT!scSV1kDAfVXg?kzblR$j3pNas0;pYJ5zM`8I04q40$cLK< zRc;bMe#)(Jm*Zs2!|BU#Usm{cd^g4R*^FTGbWM*cPyG@Kg?*0)fO+aIpr75Mh@84+ zgA5#n6hRj`dZ&fR5!N+*y|SN6g>!BeNmKDnN^V^R?8Jp6|CG-!7c#3rpj>BuN3huO z<(}Q+M44kGNrd%*VYI?*jGbU76z|lzsD`ODxQ0CaU2g=j^0>Hrvbj1C*>4BwK~?Vo zRWDn96{xX+)u|eh=>#I9I&sX-d}d6Qp*lffFsP7R!E^c?;2&MKmKRy$_-1KoSy$-q!Tq(U#h9qs|n~dAoXM+@s5g{&#Z}iTHzg^a;)rAMsEO&MYA29 zL)7e~ui9%Q#|a~zo+Rc_-)jhHptT4PkbqiCPs?yEFDJ(exyK-+pJh?BuqcoidZK2+ zhF>09cXJx7R=$kwl0A;c<1$O8@3a_sZ*~&9>$hMg_As7<#q7e zttjw0h1+R#$5>fiI;NhaE2qfN+|uv_P-4h|MQxuOa@D(=p1`PldIHZ8QQDjXoHc46 z9|?PfqlVnDG4+}sfNJvs{3&=0zm{A8LB%{q+rdJQrzXE5vZPIDu*Ws>{v9; yx1bxWP&7+<7u0D=2fhxQUxed*J*T44urAcx51Z_N-{-(S2lhFz&w+m#4*V~6p29l- From 4979050c5a18708debebd1d1b348ed09632adb16 Mon Sep 17 00:00:00 2001 From: hhhhsc <1710496817@qq.com> Date: Tue, 27 Jan 2026 21:37:13 +0800 Subject: [PATCH 3/4] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A9=BA=E5=80=BC?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- runtime/python-executor/datamate/core/base_op.py | 12 ++++++++++-- 1 file changed, 10 insertions(+), 2 deletions(-) diff --git a/runtime/python-executor/datamate/core/base_op.py b/runtime/python-executor/datamate/core/base_op.py index f87457d7..bd91d14e 100644 --- a/runtime/python-executor/datamate/core/base_op.py +++ b/runtime/python-executor/datamate/core/base_op.py @@ -205,7 +205,15 @@ def __call__(self, sample: Dict[str, Any], **kwargs): sample["execute_status"] = execute_status # 加载文件成功执行信息到数据库 if self.is_last_op: - self.save_file_and_db(sample) + # 文件无内容会被过滤 + if sample[self.text_key] == "" and sample[self.data_key] == b"": + task_info = TaskInfoPersistence() + sample[self.filesize_key] = "0" + sample[self.filetype_key] = "" + task_info.update_task_result(sample) + return sample + else: + self.save_file_and_db(sample) return sample def execute(self, sample: Dict[str, Any]) -> Dict[str, Any]: @@ -450,7 +458,7 @@ def execute(self, sample: Dict[str, Any]): if sample[self.text_key] == '' and sample[self.data_key] == b'': sample[self.filesize_key] = "0" - return False + return True if save_path: save_path = self.save_file(sample, save_path) From 7535355ed211f6647a9ba3b26d4cc9a397f46a36 Mon Sep 17 00:00:00 2001 From: hhhhsc <1710496817@qq.com> Date: Wed, 28 Jan 2026 09:15:57 +0800 Subject: [PATCH 4/4] =?UTF-8?q?=E5=A2=9E=E5=8A=A0=E7=A9=BA=E5=80=BC?= =?UTF-8?q?=E5=A4=84=E7=90=86?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- runtime/python-executor/datamate/core/base_op.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/runtime/python-executor/datamate/core/base_op.py b/runtime/python-executor/datamate/core/base_op.py index bd91d14e..c0256c17 100644 --- a/runtime/python-executor/datamate/core/base_op.py +++ b/runtime/python-executor/datamate/core/base_op.py @@ -458,7 +458,7 @@ def execute(self, sample: Dict[str, Any]): if sample[self.text_key] == '' and sample[self.data_key] == b'': sample[self.filesize_key] = "0" - return True + return False if save_path: save_path = self.save_file(sample, save_path)