hello Prefect team, hello community, is there more information available on how to make the ray autoscaler and prefect 2 task concurrency limits work smoothly together? currently, when i submit a large number of tasks with a concurrency limit tag, the ray autoscaler will see the large amount of tasks and scale accordingly, however only a small number of tasks is allowed to run concurrently due to tag limits and most of the upscaled resources won't be used, which causes unnecessary costs especially for tasks with high resource requirements.
i think this is due to the fact that the concurrency limit check happens during propose_state which happens inside the call that is submitted to the task runner. is there any way how this can be avoided? thanks a lot for any input.
Justin Trautmann
12/29/2022, 3:35 PM
@Jeff Hale do you have any input on this?
j
Jeff Hale
12/29/2022, 4:35 PM
Hi Justin. If I understand your question correctly, you are trying to avoid Ray scaling up lots of unnecessary resources. You would like the concurrency limit check to occur earlier, is that correct?
If so, I do not know of a way to achieve that. I suggest you open a feature enhancement issue on GitHub.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.