Sha256: 7b0a350b910843bc9624502058e37fff0b5500e8228a9c490d117b5713f8b920
Contents?: true
Size: 1.07 KB
Versions: 10
Compression:
Stored size: 1.07 KB
Contents
module Actions
module Pulp3
module ContentViewVersion
class Import < Pulp3::AbstractAsyncTask
input_format do
param :content_view_version_id, Integer
param :smart_proxy_id, Integer
param :importer_data, Hash
param :path, String
param :metadata, Hash
end
def invoke_external_task
cvv = ::Katello::ContentViewVersion.find(input[:content_view_version_id])
output[:pulp_tasks] = ::Katello::Pulp3::ContentViewVersion::Import.new(
smart_proxy: smart_proxy,
content_view_version: cvv,
path: input[:path],
metadata: input[:metadata]
).create_import(input[:importer_data][:pulp_href])
end
def rescue_strategy_for_self
# There are various reasons the importing fails, not all of them are
# fatal: when fail on import, we continue with the task ending up
# in the warning state, but not locking further imports
Dynflow::Action::Rescue::Skip
end
end
end
end
end
Version data entries
10 entries across 10 versions & 1 rubygems