app/workers/thread_resolve_worker.rb

   1 # frozen_string_literal: true
   2
   3 class ThreadResolveWorker
   4   include Sidekiq::Worker
   5   include ExponentialBackoff
   6
   7   sidekiq_options queue: 'pull', retry: 3
   8
   9   def perform(child_status_id, parent_url)
  10     child_status  = Status.find(child_status_id)
  11     parent_status = FetchRemoteStatusService.new.call(parent_url)
  12
  13     return if parent_status.nil?
  14
  15     child_status.thread = parent_status
  16     child_status.save!
  17   end
  18 end