fetch_replies_worker.rb 360 B

1234567891011121314
  1. # frozen_string_literal: true
  2. class ActivityPub::FetchRepliesWorker
  3. include Sidekiq::Worker
  4. include ExponentialBackoff
  5. sidekiq_options queue: 'pull', retry: 3
  6. def perform(parent_status_id, replies_uri)
  7. ActivityPub::FetchRepliesService.new.call(Status.find(parent_status_id), replies_uri)
  8. rescue ActiveRecord::RecordNotFound
  9. true
  10. end
  11. end