diff --git a/funcx_endpoint/funcx_endpoint/strategies/simple.py b/funcx_endpoint/funcx_endpoint/strategies/simple.py index 0e6fb3bb0..c9ada573e 100644 --- a/funcx_endpoint/funcx_endpoint/strategies/simple.py +++ b/funcx_endpoint/funcx_endpoint/strategies/simple.py @@ -47,7 +47,17 @@ def strategize(self, *args, **kwargs): def _strategize(self, *args, **kwargs): task_breakdown = self.interchange.get_outstanding_breakdown() - logger.info(f"Task breakdown {task_breakdown}") + + info_log = False + for breakdown_item in task_breakdown: + 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}") min_blocks = self.interchange.provider.min_blocks max_blocks = self.interchange.provider.max_blocks