From 3a290a66dd010f047a2a0fc3e983c44dfadb71fa Mon Sep 17 00:00:00 2001 From: Ahmed Ezzat Date: Mon, 18 Sep 2023 18:36:17 +0300 Subject: [PATCH] Added missing await --- dask_kubernetes/operator/controller/controller.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dask_kubernetes/operator/controller/controller.py b/dask_kubernetes/operator/controller/controller.py index e8baff1e3..b6ea6c17d 100644 --- 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: