diff --git a/app/jobs/inboxes/fetch_imap_email_inboxes_job.rb b/app/jobs/inboxes/fetch_imap_email_inboxes_job.rb index b360940e3..151f1f13c 100644 --- a/app/jobs/inboxes/fetch_imap_email_inboxes_job.rb +++ b/app/jobs/inboxes/fetch_imap_email_inboxes_job.rb @@ -1,5 +1,5 @@ class Inboxes::FetchImapEmailInboxesJob < ApplicationJob - queue_as :scheduled_jobs + queue_as :1_min_mailer def perform Inbox.where(channel_type: 'Channel::Email').all.find_each(batch_size: 100) do |inbox| diff --git a/app/jobs/inboxes/fetch_imap_emails_job.rb b/app/jobs/inboxes/fetch_imap_emails_job.rb index 23bc1c868..53772c2cb 100644 --- a/app/jobs/inboxes/fetch_imap_emails_job.rb +++ b/app/jobs/inboxes/fetch_imap_emails_job.rb @@ -1,7 +1,7 @@ require 'net/imap' class Inboxes::FetchImapEmailsJob < MutexApplicationJob - queue_as :scheduled_jobs + queue_as :1_min_mailer def perform(channel, interval = 1) return unless should_fetch_email?(channel) diff --git a/config/schedule.yml b/config/schedule.yml index a92960db8..1583d4b86 100644 --- a/config/schedule.yml +++ b/config/schedule.yml @@ -25,7 +25,7 @@ trigger_imap_email_inboxes_job: remove_stale_contact_inboxes_job.rb: cron: '30 22 * * *' class: 'Internal::RemoveStaleContactInboxesJob' - queue: scheduled_jobs + queue: 1_min_mailer # executed daily at 2230 UTC # which is our lowest traffic time diff --git a/config/sidekiq/default.yml b/config/sidekiq/default.yml index 25957ab42..f970beb42 100644 --- a/config/sidekiq/default.yml +++ b/config/sidekiq/default.yml @@ -22,6 +22,7 @@ - mailers - action_mailbox_routing - low + - 1_min_mailer - async_database_migration - active_storage_analysis - active_storage_purge