Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Add support for Kueue scheduling options to RayJob runner #24

Merged
merged 2 commits into from
Apr 30, 2024

Conversation

AdrianoKF
Copy link
Collaborator

This PR adds support for the Kueue SchedulingOptions in the job options to the RayJob runner.
This enables job priorities and preemption to be used by Ray jobs if Kueue is available in the Kubernetes cluster.

Internally, the util module has been refactored into a proper package for better usability, since it was growing into a mixed bag of unrelated functions.

@AdrianoKF AdrianoKF self-assigned this Apr 30, 2024
@AdrianoKF AdrianoKF added the enhancement New feature or request label Apr 30, 2024
Copy link
Collaborator

@nicholasjng nicholasjng left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nice work!

from jobs.utils.helpers import remove_none_values


def assert_kueue_localqueue(namespace: str, name: str) -> bool:
Copy link
Collaborator

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Nit: I don't love assert as the leading part of these functions, since they do not use assertions but API lookups (which is of course 1000x better). But at this time it's an internal detail, so I'm good with leaving it like this.

@nicholasjng nicholasjng merged commit de1a4cc into main Apr 30, 2024
2 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
enhancement New feature or request
Projects
None yet
Development

Successfully merging this pull request may close these issues.

3 participants