Log if necessary

dask · Sep 18, 2023 · 55398ea · 55398ea
1 parent 76a288e
commit 55398ea
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py
@@ -600,9 +600,10 @@ async def daskworkergroup_replica_update(
                 if not worker.ready() and len(pending_workers) <= -workers_needed:
                     pending_workers.append(worker)
 
-            logger.info(f"Pending worker deployments to delete: {pending_workers}")
-            for worker in pending_workers:
-                await worker.delete()
+            if pending_workers:
+                logger.info(f"Pending worker deployments to delete: {pending_workers}")
+                for worker in pending_workers:
+                    await worker.delete()
 
             n_workers = -workers_needed - len(pending_workers)
             if n_workers > 0: