Sha256: cf7d21a69cbe823d39e68567ef80f2f1846c0e8e7d7d9b18ddc576fa228ec900
Contents?: true
Size: 737 Bytes
Versions: 9
Compression:
Stored size: 737 Bytes
Contents
module Actions
module Pulp
module Consumer
class AbstractNodeDistributorTask < Pulp::AbstractAsyncTask
def invoke_external_task
fail NotImplementedError
end
protected
def distributor
@distributor ||= repo_details['distributors'].find do |distributor|
distributor["distributor_type_id"] == Runcible::Models::NodesHttpDistributor.type_id
end
unless @distributor
fail "Could not find node distributor for repository %s" % input[:repo_id]
end
@distributor
end
def repo_details
pulp_extensions.repository.retrieve_with_details(input[:repo_id])
end
end
end
end
end
Version data entries
9 entries across 9 versions & 1 rubygems