nyastodon/app/workers/thread_resolve_worker.rb

# frozen_string_literal: true

class ThreadResolveWorker
  include Sidekiq::Worker

  sidekiq_options queue: 'pull', retry: false

  def perform(child_status_id, parent_url)
    child_status  = Status.find(child_status_id)
    parent_status = FetchRemoteStatusService.new.call(parent_url)

    return if parent_status.nil?

    child_status.thread = parent_status
    child_status.save!
  end
end
Restoring old async behaviour of thread resolving as it proved to be more robust 2016-12-12 21:12:19 +01:00			`# frozen_string_literal: true`

			`class ThreadResolveWorker`
			`include Sidekiq::Worker`

Separate background jobs into different queues. ATTENTION: new queue "pull" must be added to the Sidekiq invokation in your systemd file The pull queue will handle link crawling, thread resolving, and OStatus processing. Such tasks are more likely to hang for a longer time (due to network requests) so it is more sensible to not make the "in-house" tasks wait for them. 2017-04-04 00:53:20 +02:00			`sidekiq_options queue: 'pull', retry: false`
Improve background jobs params and error handling 2017-01-05 03:28:21 +01:00
Restoring old async behaviour of thread resolving as it proved to be more robust 2016-12-12 21:12:19 +01:00			`def perform(child_status_id, parent_url)`
			`child_status = Status.find(child_status_id)`
			`parent_status = FetchRemoteStatusService.new.call(parent_url)`

			`return if parent_status.nil?`

			`child_status.thread = parent_status`
			`child_status.save!`
			`end`
			`end`