-
Notifications
You must be signed in to change notification settings - Fork 2
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 idle job preemption #1927
add idle job preemption #1927
Conversation
Codecov Report
@@ Coverage Diff @@
## master #1927 +/- ##
==========================================
+ Coverage 92.54% 92.60% +0.05%
==========================================
Files 40 41 +1
Lines 6644 6897 +253
Branches 1060 1105 +45
==========================================
+ Hits 6149 6387 +238
- Misses 367 376 +9
- Partials 128 134 +6
Flags with carried forward coverage won't be shown. Click here to find out more.
|
22e7d22
to
d8a8239
Compare
@@ -167,12 +150,13 @@ def orchestrator_config(self) -> OrchestratorConfig: | |||
def kube_config(self) -> KubeConfig: | |||
return self._kube_config | |||
|
|||
# TODO: remove |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
cleanup later to avoid unnecessary changes in pr
d5b4668
to
29674ae
Compare
cd2bd8a
to
dd1196a
Compare
@@ -875,3 +862,7 @@ async def delete_all_job_resources(self, job_id: str) -> None: | |||
await self._client.delete_all_ingresses(labels=labels) | |||
await self._client.delete_all_services(labels=labels) | |||
await self._client.delete_all_network_policies(labels=labels) | |||
|
|||
async def preempt_idle_jobs(self, jobs_to_schedule: list[Job]) -> None: |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Currently not used anywhere. Requires K8s upgrade to at least 1.19 of all clusters
No description provided.