Optimize the query task and do not execute it when there is no data w…

…hen executing reduce
snower · Mar 20, 2024 · 6448932 · 6448932
1 parent 5d47f79
commit 6448932
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/syncanysql/taskers/query.py b/syncanysql/taskers/query.py
@@ -33,6 +33,8 @@ def __init__(self, executor, session_config, manager, arguments, tasker, config,
         self.batch_count = 0
 
     def outputed(self, tasker, datas):
+        if not datas:
+            return
         if self.batch > 0 and self.count > 0 and self.count + len(datas) >= self.batch:
             self.count, self.batch_count = 0, 1
             self.tasker.run_reduce(self.executor, self.session_config, self.manager, self.arguments, False)