template = if lookup and lookup[self.pipeline_template_uuid]
lookup[self.pipeline_template_uuid]
else
- PipelineTemplate.where(uuid: self.pipeline_template_uuid).first
+ PipelineTemplate.find?(self.pipeline_template_uuid) if self.pipeline_template_uuid
end
if template
template.name
components_map { |cspec| cspec[:job][:log] rescue nil }
end
+ def job_ids
+ components_map { |cspec| cspec[:job][:uuid] rescue nil }
+ end
+
def stderr_log_object_uuids
result = job_uuids.values.compact
result << uuid
end
end
+ def work_unit(label=nil)
+ PipelineInstanceWorkUnit.new(self, label || self.name)
+ end
+
private
def components_map