We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 2321ff7 commit 55e358eCopy full SHA for 55e358e
inference/tasks.py
@@ -18,6 +18,10 @@ def process_inference_job_queue():
18
return "Queue processing already in progress"
19
20
try:
21
+ # Reevaluate progress and update status of all inference jobs that are not currently queued
22
+ for job in InferenceJob.objects.exclude(status=InferenceJobStatus.QUEUED):
23
+ job.reevaluate_progress_and_update_status()
24
+
25
# Look for pending jobs first
26
pending_jobs = InferenceJob.objects.filter(status=InferenceJobStatus.PENDING)
27
0 commit comments