Merge pull request #5606 from tchak/more-queues

Run jobs in named queues
2020-09-23 09:43:46 +02:00 · 2020-09-23 09:43:46 +02:00 · a7e4720d0d
commit a7e4720d0d
parent e0e635d65b dea78c49f6
3 changed files with 6 additions and 0 deletions
--- a/app/jobs/api_entreprise/job.rb
+++ b/app/jobs/api_entreprise/job.rb
@ -1,4 +1,6 @@
 class ApiEntreprise::Job < ApplicationJob
+  queue_as :api_entreprise
+
  DEFAULT_MAX_ATTEMPTS_API_ENTREPRISE_JOBS = 5

  rescue_from(ApiEntreprise::API::ResourceNotFound) do |exception|
--- a/app/jobs/export_job.rb
+++ b/app/jobs/export_job.rb
@ -1,4 +1,6 @@
 class ExportJob < ApplicationJob
+  queue_as :exports
+
  def perform(export)
    export.compute
  end
--- a/app/jobs/web_hook_job.rb
+++ b/app/jobs/web_hook_job.rb
@ -1,4 +1,6 @@
 class WebHookJob < ApplicationJob
+  queue_as :webhooks_v1
+
  TIMEOUT = 10

  def perform(procedure, dossier)