random-mirrors
/
gab-social
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Update popular activitypub workers to max_retries: 3 

• Update:
- popular activitypub workers (DeliveryWorker, LowPriorityDeliveryWorker, ProcessingWorker)to max_retries: 3
This commit is contained in:
mgabdev 2020-05-26 22:24:12 -04:00
parent 8aff80141b
commit c1c966a2e1
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
app/workers/activitypub/delivery_worker.rb
View File

@ -6,7 +6,7 @@ class ActivityPub::DeliveryWorker
STOPLIGHT_FAILURE_THRESHOLD = 10 STOPLIGHT_FAILURE_THRESHOLD = 10
STOPLIGHT_COOLDOWN = 60 STOPLIGHT_COOLDOWN = 60
sidekiq_options queue: 'push', retry: 16, dead: false sidekiq_options queue: 'push', retry: 3, dead: false
HEADERS = { 'Content-Type' => 'application/activity+json' }.freeze HEADERS = { 'Content-Type' => 'application/activity+json' }.freeze

2
app/workers/activitypub/low_priority_delivery_worker.rb
View File

@ -1,5 +1,5 @@
# frozen_string_literal: true # frozen_string_literal: true
class ActivityPub::LowPriorityDeliveryWorker < ActivityPub::DeliveryWorker class ActivityPub::LowPriorityDeliveryWorker < ActivityPub::DeliveryWorker
sidekiq_options queue: 'pull', retry: 8, dead: false sidekiq_options queue: 'pull', retry: 3, dead: false
end end

2
app/workers/activitypub/processing_worker.rb
View File

@ -3,7 +3,7 @@
class ActivityPub::ProcessingWorker class ActivityPub::ProcessingWorker
include Sidekiq::Worker include Sidekiq::Worker
sidekiq_options backtrace: true sidekiq_options backtrace: true, retry: 3
def perform(account_id, body, delivered_to_account_id = nil) def perform(account_id, body, delivered_to_account_id = nil)
ActivityPub::ProcessCollectionService.new.call(body, Account.find(account_id), override_timestamps: true, delivered_to_account_id: delivered_to_account_id, delivery: true) ActivityPub::ProcessCollectionService.new.call(body, Account.find(account_id), override_timestamps: true, delivered_to_account_id: delivered_to_account_id, delivery: true)