Sha256: c9ed3ca068449f4d6f80b4ca108a49dcab93cf6c85dae6faecada094f915d8ab
Contents?: true
Size: 888 Bytes
Versions: 46
Compression:
Stored size: 888 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
46 entries across 46 versions & 1 rubygems