Change incoming activity processing to happen in ingress queue (#20264)

2024-11-16 20:22:18 +00:00 · 2022-11-10 14:21:51 +01:00 · 2022-11-10 14:21:51 +01:00 · f8e8e622e5
parent 89a6b76f99
commit f8e8e622e5
3 changed files with 5 additions and 3 deletions
--- a/app/lib/admin/system_check/sidekiq_process_check.rb
+++ b/app/lib/admin/system_check/sidekiq_process_check.rb
@ -7,6 +7,7 @@ class Admin::SystemCheck::SidekiqProcessCheck < Admin::SystemCheck::BaseCheck
    mailers
    pull
    scheduler
+    ingress
  ).freeze

  def skip?
--- a/app/workers/activitypub/processing_worker.rb
+++ b/app/workers/activitypub/processing_worker.rb
@ -3,7 +3,7 @@
 class ActivityPub::ProcessingWorker
  include Sidekiq::Worker

-  sidekiq_options backtrace: true, retry: 8
+  sidekiq_options queue: 'ingress', backtrace: true, retry: 8

  def perform(actor_id, body, delivered_to_account_id = nil, actor_type = 'Account')
    case actor_type
--- a/config/sidekiq.yml
+++ b/config/sidekiq.yml
@ -1,8 +1,9 @@
 ---
 :concurrency: 5
 :queues:
-  - [default, 6]
-  - [push, 4]
+  - [default, 8]
+  - [push, 6]
+  - [ingress, 4]
  - [mailers, 2]
  - [pull]
  - [scheduler]