Fix poller service failure when there is suspended job in cluster

neuro-inc · Nov 28, 2023 · 98256ee · 98256ee
1 parent 776cdd1
commit 98256ee
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/platform_api/orchestrator/poller_service.py b/platform_api/orchestrator/poller_service.py
@@ -25,7 +25,7 @@
 from ..utils.asyncio import run_and_log_exceptions
 from ..utils.retry import retries
 from .base import Orchestrator
-from .job import Job, JobRecord, JobStatusItem, JobStatusReason
+from .job import Job, JobPriority, JobRecord, JobStatusItem, JobStatusReason
 from .job_request import (
     JobAlreadyExistsException,
     JobError,
@@ -199,6 +199,7 @@ async def schedule(self, unfinished: list[JobRecord]) -> SchedulingResult:
                 continue
             jobs_to_start.append(job)
 
+        max_job_to_start_priority = JobPriority.LOW
         if jobs_to_start:
             max_job_to_start_priority = max(job.priority for job in jobs_to_start)