Sha256: a9b1c94bd51d115acdf1ebbcc3875ab7958746f88be285a945211c20862537cf
Contents?: true
Size: 715 Bytes
Versions: 137
Compression:
Stored size: 715 Bytes
Contents
module Actions
module Candlepin
class AsyncHypervisors < Candlepin::AbstractAsyncTask
# this action is for tracking an async candlepin task when the task id is already known
input_format do
param :task_id
end
def poll_external_task(task_id = external_task[:id])
task = ::Katello::Resources::Candlepin::Job.get(task_id, :result_data => true)
unless ::Katello::Resources::Candlepin::Job.not_finished?(task)
output[:hypervisors] = ::Actions::Katello::Host::Hypervisors.parse_hypervisors(task.delete('resultData'))
end
task
end
def invoke_external_task
poll_external_task(input[:task_id])
end
end
end
end
Version data entries
137 entries across 137 versions & 1 rubygems