Warteschlange in Delayed_Job mit ActiveJobs

Question

In einem Controller habe ich eine Postanforderung von einem authentifizierten Benutzer, der einen ActiveJob auslöst.

RunReportsJob.perform_later(param1, param2, param3) 

Es funktioniert ohne Fehler. Wenn der Benutzer jedoch die Schaltfläche (Abschiebeanforderung) erneut drückt, um RunReportsJob auszulösen, während er bereits ausgeführt wurde, werden gleichzeitig zwei Jobs ausgeführt. Ich habe delayed_job eingerichtet, weil ich dachte, es wäre ein Warteschlangen-Service, und würde alles auf einmal erledigen. Aber das passiert nicht. Im Folgenden finden Sie meine Konfiguration:

# app/jobs/run_reports_job.rb:

class RunReportsJob < ActiveJob::Base 
     queue_as :RunReports 
     include ShopifyApp::Controller 
     # -------------------------------------------------------------- 
     # JOB ERROR MANAGEMENT 
     # -------------------------------------------------------------- 
     rescue_from(ActiveRecord::RecordNotFound) do |exception| 
      # Do something with the exception 
      logger.debug "Hit rescue_from" 
     end 
     # -------------------------------------------------------------- 
     # JOB FUNCTION 
     # -------------------------------------------------------------- 
     def perform(param1, param2, param3) 
     # some code is performed here 
     end 
end 

:

config.active_job.queue_adapter = :delayed_job 

# config/initializers/delayed_job_config.rb:

Delayed::Worker.max_attempts = 1 
Delayed::Worker.max_run_time = 12.hours 

Answer 1

Sie werden einige Logik vor RunReportsJob.perform_later(param1, param2, param3) hinzufügen müssen für eine bereits zu überprüfen Auftragspriorität y und erhöhen die Prioritätszahl (kleinere Zahl eine höhere Priorität Dokumentation nach) in diesem Beispiel die Warteschlange:

highest_priority = Delayed::Job.where(queue: :RunReports).maximum(:priority) 
Delayed::Worker.default_priority = highest_priority + 1 if highest_priority 

RunReportsJob.perform_later(param1, param2, param3) 

DelayedJob verwendet eine Tabelle der Jobs alle Infos bei https://github.com/collectiveidea/delayed_job#gory-details