Added missing await

dask · Sep 18, 2023 · 3a290a6 · 3a290a6
1 parent 55398ea
commit 3a290a6
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py
@@ -597,7 +597,7 @@ async def daskworkergroup_replica_update(
         if workers_needed < 0:
             pending_workers = []
             for worker in current_workers:
-                if not worker.ready() and len(pending_workers) <= -workers_needed:
+                if not await worker.ready() and len(pending_workers) <= -workers_needed:
                     pending_workers.append(worker)
 
             if pending_workers: