Sha256: f5acf7011920597398b013a056c9528fa2997dbcb3eeb5f9cbeccc66aac42fd6
Contents?: true
Size: 800 Bytes
Versions: 12
Compression:
Stored size: 800 Bytes
Contents
module Actions
module Pulp
module Repository
class Refresh < Pulp::AbstractAsyncTask
input_format do
param :capsule_id
param :pulp_id
end
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
end
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems