Sha256: f0dee30fff109e65359b8c1e19613be8cfb9b78029ff3ea076ab117f9c803734
Contents?: true
Size: 887 Bytes
Versions: 117
Compression:
Stored size: 887 Bytes
Contents
module Actions
module Candlepin
class AbstractAsyncTask < Candlepin::Abstract
include Actions::Base::Polling
def run(event = nil)
# do nothing when the action is being skipped
unless event == Dynflow::Action::Skip
super
end
end
def humanized_state
case state
when :running
if self.external_task.nil?
_("initiating Candlepin task")
else
_("checking Candlepin task status")
end
when :suspended
_("waiting for Candlepin to finish the task")
else
super
end
end
def done?
!::Katello::Resources::Candlepin::Job.not_finished?(external_task)
end
private
def poll_external_task
::Katello::Resources::Candlepin::Job.get(external_task[:id])
end
end
end
end
Version data entries
117 entries across 117 versions & 1 rubygems