From 91c96ce6c1c67d8a97544fac2748c2bbeee4f03c Mon Sep 17 00:00:00 2001 From: yongyanrao Date: Wed, 23 Jun 2021 10:21:06 -0500 Subject: [PATCH] Changed from summing to individual check --- funcx_endpoint/funcx_endpoint/strategies/simple.py | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) diff --git a/funcx_endpoint/funcx_endpoint/strategies/simple.py b/funcx_endpoint/funcx_endpoint/strategies/simple.py index a23adc965..c9ada573e 100644 --- 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}")