Sha256: 42a5cb33cf8f58ff17d1a074fb9cb9dc1a370cf6362667b9b6bed907f055a09c
Contents?: true
Size: 1.34 KB
Versions: 83
Compression:
Stored size: 1.34 KB
Contents
module Actions
module Pulp
module Repository
class CopyAllUnits < Pulp::AbstractAsyncTask
def plan(target_repo, _smart_proxy, source_repo, options = {})
filter_ids = options.fetch(:filters, nil)&.map(&:id)
rpm_filenames = options.fetch(:rpm_filenames, nil)
solve_dependencies = options.fetch(:solve_dependencies, false)
plan_self(source_repo_id: source_repo.id,
target_repo_id: target_repo.id,
filter_ids: filter_ids,
solve_dependencies: solve_dependencies,
rpm_filenames: rpm_filenames)
end
def invoke_external_task
source_repo = ::Katello::Repository.find(input[:source_repo_id])
target_repo = ::Katello::Repository.find(input[:target_repo_id])
filters = ::Katello::ContentViewFilter.where(:id => input[:filter_ids])
source_repo.backend_service(SmartProxy.pulp_primary).copy_contents(target_repo,
filters: filters,
solve_dependencies: input[:solve_dependencies],
rpm_filenames: input[:rpm_filenames])
end
end
end
end
end
Version data entries
83 entries across 83 versions & 1 rubygems