lower priority (#85)

salesforce · Oct 23, 2024 · 689cfe9 · 689cfe9
1 parent f50dd15
commit 689cfe9
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/app/jobs/sync_quip_doc_job.rb b/app/jobs/sync_quip_doc_job.rb
@@ -31,7 +31,7 @@ def perform(_doc_id)
       document.last_sync_result = 'SUCCESS'
       document.save!
       # Reschedule the job to run again in 24 hours
-      SyncQuipDocJob.set(wait: 24.hours).perform_later(_doc_id)
+      SyncQuipDocJob.set(wait: 24.hours, priority: 10).perform_later(_doc_id)
       return
     rescue ActiveRecord::RecordInvalid => e
       # Handle save! failures (validation errors)
@@ -49,6 +49,6 @@ def perform(_doc_id)
 
     document.last_sync_result = 'FAILED'
     document.save
-    SyncQuipDocJob.set(wait: 30.minutes).perform_later(_doc_id)
+    SyncQuipDocJob.set(wait: 30.minutes, priority: 10).perform_later(_doc_id)
   end
 end
diff --git a/app/models/document.rb b/app/models/document.rb
@@ -94,7 +94,7 @@ def sync_quip_doc_if_needed
 
     self.last_sync_result = 'SCHEDULED'
 
-    SyncQuipDocJob.set(wait: 5.seconds).perform_later(id) # Add delay to prevent race condition with schedule jobs
+    SyncQuipDocJob.set(wait: 5.seconds, priority: 10).perform_later(id) # Add delay to prevent race condition with schedule jobs
   end
 
   # Schedule the EmbedDocumentJob with a delay based on the number of jobs in the queue