Sha256: 57981db049c0b0c5770fafbed8445daee403bdfe2f7379819ea77410740a6f00
Contents?: true
Size: 1.16 KB
Versions: 5
Compression:
Stored size: 1.16 KB
Contents
module Actions
module Pulp
module Repository
class CopyUnits < Pulp::AbstractAsyncTask
def plan(source_repo, target_repo, units, options = {})
if units.any?
plan_self(source_repo_id: source_repo.id,
target_repo_id: target_repo.id,
class_name: units.first.class.name,
unit_ids: units.pluck(:id),
recursive: options[:recursive],
resolve_dependencies: options[:resolve_dependencies])
end
end
def invoke_external_task
source_repo = ::Katello::Repository.find(input[:source_repo_id])
target_repo = ::Katello::Repository.find(input[:target_repo_id])
units = input[:class_name].constantize.where(:id => input[:unit_ids])
source_repo.backend_service(SmartProxy.pulp_master).copy_units(target_repo, units,
recursive: input[:recursive],
resolve_dependencies: input[:resolve_dependencies])
end
end
end
end
end
Version data entries
5 entries across 5 versions & 1 rubygems