Sha256: a9a5ed9daff5ab7cac12139c63829ba6140b7848b9d60e57988868a829fdee94
Contents?: true
Size: 1.48 KB
Versions: 11
Compression:
Stored size: 1.48 KB
Contents
module Actions
module Katello
module CapsuleContent
class SyncCapsule < ::Actions::EntryAction
include Actions::Katello::PulpSelector
# rubocop:disable MethodLength
def plan(smart_proxy, options = {})
action_subject(smart_proxy)
environment = options[:environment]
content_view = options[:content_view]
repository = options[:repository]
skip_metadata_check = options.fetch(:skip_metadata_check, false)
smart_proxy_helper = ::Katello::SmartProxyHelper.new(smart_proxy)
concurrence do
smart_proxy_helper.repos_available_to_capsule(environment, content_view, repository).each do |repo|
plan_pulp_action([Actions::Pulp::Orchestration::Repository::SmartProxySync,
Actions::Pulp3::CapsuleContent::Sync],
repo, smart_proxy,
skip_metadata_check: skip_metadata_check)
if repo.is_a?(::Katello::Repository) &&
repo.distribution_bootable? &&
repo.download_policy == ::Runcible::Models::YumImporter::DOWNLOAD_ON_DEMAND
plan_action(Katello::Repository::FetchPxeFiles,
id: repo.id,
capsule_id: smart_proxy.id)
end
end
end
end
def rescue_strategy
Dynflow::Action::Rescue::Skip
end
end
end
end
end
Version data entries
11 entries across 11 versions & 1 rubygems