more cleanup

IBM · Nov 21, 2024 · d559a2e · d559a2e
1 parent 33f581a
commit d559a2e
Showing 1 changed file with 1 addition and 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
@@ -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: