mastodon/app/workers/import_worker.rb

# frozen_string_literal: true

# NOTE: This is a deprecated worker, only kept to not break ongoing imports
# on upgrade. See `ImportWorker` for its replacement.

class ImportWorker
  include Sidekiq::Worker

  sidekiq_options queue: 'pull', retry: false

  def perform(import_id)
    import = Import.find(import_id)
    ImportService.new.call(import)
  ensure
    import&.destroy
  end
end
Import feature for following/blocking lists (addresses #62, #177, #201, #454) 2017-03-30 17:42:33 +00:00			`# frozen_string_literal: true`

Rewrite import feature (#21054) 2023-05-02 10:08:48 +00:00			`# NOTE: This is a deprecated worker, only kept to not break ongoing imports`
			# on upgrade. See `ImportWorker` for its replacement.

Import feature for following/blocking lists (addresses #62, #177, #201, #454) 2017-03-30 17:42:33 +00:00			`class ImportWorker`
			`include Sidekiq::Worker`
Followers-only post federation (#2111) * Make private toots get PuSHed to subscription URLs that belong to domains where you have approved followers * Authorized followers controller, stub for bulk action * Soft block in the background * Add simple test for new controller * Rename Settings::FollowersController to Settings::FollowerDomainsController, paginate results, rename "private" post setting to "followers-only", fix pagination style, improve post privacy preferences style, improve warning style * Extract compose form warnings into own container, show warning when posting to followers-only with unlocked account 2017-04-23 22:38:37 +00:00
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-03 22:53:20 +00:00			`sidekiq_options queue: 'pull', retry: false`
Import feature for following/blocking lists (addresses #62, #177, #201, #454) 2017-03-30 17:42:33 +00:00
			`def perform(import_id)`
Add option to overwrite imported data (#9962) * Add option to overwrite imported data Fix #7465 * Add import for domain blocks 2019-02-03 02:59:51 +00:00			`import = Import.find(import_id)`
			`ImportService.new.call(import)`
			`ensure`
			`import&.destroy`
Import feature for following/blocking lists (addresses #62, #177, #201, #454) 2017-03-30 17:42:33 +00:00			`end`
			`end`