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 d5e6754ac..ff6e53892 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 @@ -22,6 +22,9 @@ from ray.util.actor_pool import ActorPool +# This value matches the constant `RAY_MAX_LIMIT_FROM_API_SERVER` defined in the ray source code here: +# https://github.com/ray-project/ray/blob/569f7df9067c5654fb57ba7bc4792b3ba5aaa846/python/ray/util/state/common.py#L50-L53 + RAY_MAX_ACTOR_LIMIT = 10000