Changed from summing to individual check

globus · Jun 23, 2021 · 91c96ce · 91c96ce
1 parent bf7435f
commit 91c96ce
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/funcx_endpoint/funcx_endpoint/strategies/simple.py b/funcx_endpoint/funcx_endpoint/strategies/simple.py
@@ -47,10 +47,14 @@ def strategize(self, *args, **kwargs):
 
     def _strategize(self, *args, **kwargs):
         task_breakdown = self.interchange.get_outstanding_breakdown()
-        num_tasks = 0
+
+        info_log = False
         for breakdown_item in task_breakdown:
-            num_tasks += breakdown_item[1]
-        if num_tasks > 0:
+            if breakdown_item[1] > 0:
+                info_log = True
+                break
+
+        if info_log:
             logger.info(f"Task breakdown {task_breakdown}")
         else:
             logger.debug(f"Task breakdown {task_breakdown}")