ontohub/lib/repository_update_worker.rb

	repository_update_worker.rb revision b155a36436c57aa3920c6759ddec29f8305490c2
# Worker for Sidekiq
class RepositoryUpdateWorker < Worker

  # This worker does not play a direct role
  # in concurrency balancing, because this
  # worker only creates other Jobs down
  # the line. It cannot experience the
  # ConcurrencyBalancer::AlreadyProcessingError.
  def perform(repo_path, oldrev, newrev, refname, key_id)
    repo_path =~ /(\d+)\/?\z/
    repo_id = $1.to_i
    Repository.where(id: repo_id).first!
      .suspended_save_ontologies \
        start_oid: newrev,
        stop_oid:  oldrev,
        walk_order: Rugged::SORT_REVERSE
  end

end