Class: Workers::ArchiveBase

Inherits:
Base
  • Object
show all
Includes:
Diaspora::Logging
Defined in:
app/workers/archive_base.rb

Direct Known Subclasses

ExportUser, ImportUser

Instance Method Summary collapse

Instance Method Details

#perform(*args) ⇒ Object 



13
14
15
16
17
18
19
20
21
 
# File 'app/workers/archive_base.rb', line 13

def perform(*args)
  if currently_running_archive_jobs >= AppConfig.settings.archive_jobs_concurrency.to_i
    logger.info "Already the maximum number of parallel archive jobs running, " \
                "scheduling #{self.class}:#{args} in 5 minutes."
    self.class.perform_in(5.minutes + rand(30), *args)
  else
    perform_archive_job(*args)
  end
end