From d559a2e476154e2deb6cfb4582d8174a91ca2c9e Mon Sep 17 00:00:00 2001 From: blublinsky Date: Thu, 21 Nov 2024 19:59:34 +0000 Subject: [PATCH] more cleanup --- .../ray/src/data_processing_ray/runtime/ray/ray_utils.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/data-processing-lib/ray/src/data_processing_ray/runtime/ray/ray_utils.py b/data-processing-lib/ray/src/data_processing_ray/runtime/ray/ray_utils.py index 37419fc3e..a854e8ec3 100644 --- a/data-processing-lib/ray/src/data_processing_ray/runtime/ray/ray_utils.py +++ b/data-processing-lib/ray/src/data_processing_ray/runtime/ray/ray_utils.py @@ -120,7 +120,7 @@ def operator() -> ActorHandle: if overall < MAX_LIST: n_list = min(overall + 10, MAX_LIST) alive = [] - for i in range(1): + for i in range(120): time.sleep(1) alive = list_actors(filters=[("class_name", "=", cls_name), ("state", "=", "ALIVE")], limit=n_list) if len(alive) >= n_actors + c_len: