Sha256: 0431f3796e39d729cbe7623614b3cd1a77acce132bd39ad258350d09c353fe31
Contents?: true
Size: 720 Bytes
Versions: 114
Compression:
Stored size: 720 Bytes
Contents
module Actions
module Pulp
module Repository
class Refresh < Pulp::AbstractAsyncTask
def plan(repository, options = {})
options[:capsule_id] ||= SmartProxy.default_capsule!.id
plan_self(:capsule_id => options[:capsule_id], :pulp_id => repository.pulp_id)
end
def invoke_external_task
repo = ::Katello::Repository.find_by(:pulp_id => input[:pulp_id])
if repo.nil?
repo = ::Katello::ContentViewPuppetEnvironment.find_by(:pulp_id => input[:pulp_id])
repo = repo.nonpersisted_repository
end
repo.backend_service(smart_proxy(input[:capsule_id])).refresh_if_needed
end
end
end
end
end
Version data entries
114 entries across 114 versions & 1 rubygems