Sha256: 6e9f1988a4de8deb530a0cc60abb1b7c01cf5e3af3072106f6132566a030b9e6
Contents?: true
Size: 697 Bytes
Versions: 50
Compression:
Stored size: 697 Bytes
Contents
module Actions
module Candlepin
class UpstreamAbstractAsyncTask < AbstractAsyncTask
input_format do
param :upstream
end
def done?
check_for_errors!(external_task)
!::Katello::Resources::Candlepin::UpstreamJob.not_finished?(external_task)
end
def candlepin
_("Upstream Candlepin")
end
private
def poll_external_task
::Katello::Resources::Candlepin::UpstreamJob.get(external_task[:id], input[:upstream])
end
def check_for_errors!(task)
if task[:state] == 'FAILED'
fail ::Katello::Errors::UpstreamCandlepinError, task[:resultData]
end
end
end
end
end
Version data entries
50 entries across 50 versions & 1 rubygems