Reevaluate progress for only PENDING InferenceJobs

Author: dhanur-sharma

inference/tasks.py

@@ -19,16 +19,17 @@ def process_inference_job_queue():
 
         try:
             # Reevaluate progress and update status of all inference jobs that are not currently queued
-            for job in InferenceJob.objects.exclude(status=InferenceJobStatus.QUEUED):
-                job.reevaluate_progress_and_update_status()
+            # for job in InferenceJob.objects.exclude(status=InferenceJobStatus.QUEUED):
+            #     job.reevaluate_progress_and_update_status()
 
             # Look for pending jobs first
             pending_jobs = InferenceJob.objects.filter(status=InferenceJobStatus.PENDING)
 
             if pending_jobs.exists():
-                # Process pending jobs
+                # Refresh and process pending jobs
                 for job in pending_jobs:
                     job.refresh_external_jobs_status_and_store_results()
+                    job.reevaluate_progress_and_update_status()
             else:
                 # If no pending jobs, try to initiate a queued job
                 queued_job = (