1 class PipelineInstancesController < ApplicationController
2 skip_before_filter :find_object_by_uuid, only: :compare
3 before_filter :find_objects_by_uuid, only: :compare
4 include PipelineInstancesHelper
5 include PipelineComponentsHelper
8 template = PipelineTemplate.find?(@object.pipeline_template_uuid)
11 @object = PipelineInstance.new
12 @object.pipeline_template_uuid = source.pipeline_template_uuid
14 if params['components'] == 'use_latest' and template
15 @object.components = template.components.deep_dup
16 @object.components.each do |cname, component|
17 # Go through the script parameters of each component
18 # that are marked as user input and copy them over.
19 # Skip any components that are not present in the
20 # source instance (there's nothing to copy)
21 if source.components.include? cname
22 component[:script_parameters].each do |pname, val|
23 if val.is_a? Hash and val[:dataclass]
24 # this is user-inputtable, so check the value from the source pipeline
25 srcvalue = source.components[cname][:script_parameters][pname]
27 component[:script_parameters][pname] = srcvalue
34 @object.components = source.components.deep_dup
37 if params['script'] == 'use_same'
38 # Go through each component and copy the script_version from each job.
39 @object.components.each do |cname, component|
40 if source.components.include? cname and source.components[cname][:job]
41 component[:script_version] = source.components[cname][:job][:script_version]
46 @object.components.each do |cname, component|
51 # set owner_uuid to that of source, provided it is a project and wriable by current user
52 current_project = Group.find(source.owner_uuid) rescue nil
53 if (current_project && current_project.writable_by.andand.include?(current_user.uuid))
54 @object.owner_uuid = source.owner_uuid
61 @updates ||= params[@object.class.to_s.underscore.singularize.to_sym]
62 if (components = @updates[:components])
63 components.each do |cname, component|
64 if component[:script_parameters]
65 component[:script_parameters].each do |param, value_info|
66 if value_info.is_a? Hash
67 if resource_class_for_uuid(value_info[:value]) == Link
68 # Use the link target, not the link itself, as script
69 # parameter; but keep the link info around as well.
70 link = Link.find value_info[:value]
71 value_info[:value] = link.head_uuid
72 value_info[:link_uuid] = link.uuid
73 value_info[:link_name] = link.name
75 # Delete stale link_uuid and link_name data.
76 value_info[:link_uuid] = nil
77 value_info[:link_name] = nil
88 return nil, nil if params['tab_pane'] != "Graph"
98 p.components.each do |k, v|
101 uuid = j[:uuid].intern
103 pips[uuid] = 0 unless pips[uuid] != nil
106 collections << j[:output]
107 ProvenanceHelper::find_collections(j[:script_parameters]).each do |k|
111 uuid = j[:script_version].intern
112 provenance[uuid] = {:uuid => uuid}
113 pips[uuid] = 0 unless pips[uuid] != nil
117 Collection.where(uuid: collections.compact).each do |c|
120 pips[uuid] = 0 unless pips[uuid] != nil
127 return provenance, pips
131 @pipelines = [@object]
134 PipelineInstance.where(uuid: params[:compare]).each do |p|
139 provenance, pips = graph(@pipelines)
141 @prov_svg = ProvenanceHelper::create_provenance_graph provenance, "provenance_svg", {
143 :all_script_parameters => true,
144 :combine_jobs => :script_and_version,
145 :script_version_nodes => true,
153 @breadcrumb_page_name = 'compare'
155 @rows = [] # each is {name: S, components: [...]}
157 if params['tab_pane'] == "Compare" or params['tab_pane'].nil?
158 # Build a table: x=pipeline y=component
159 @objects.each_with_index do |pi, pi_index|
160 pipeline_jobs(pi).each do |component|
161 # Find a cell with the same name as this component but no
162 # entry for this pipeline
164 @rows.each_with_index do |row, row_index|
165 if row[:name] == component[:name] and !row[:components][pi_index]
170 target_row = {name: component[:name], components: []}
173 target_row[:components][pi_index] = component
178 # Build a "normal" pseudo-component for this row by picking the
179 # most common value for each attribute. If all values are
180 # equally common, there is no "normal".
181 normal = {} # attr => most common value
182 highscore = {} # attr => how common "normal" is
183 score = {} # attr => { value => how common }
184 row[:components].each do |pj|
187 vstr = for_comparison v
189 score[k][vstr] = (score[k][vstr] || 0) + 1
191 if score[k][vstr] == highscore[k]
192 # tie for first place = no "normal"
194 elsif score[k][vstr] == highscore[k] + 1
195 # more pipelines have v than anything else
196 highscore[k] = score[k][vstr]
202 # Add a hash in component[:is_normal]: { attr => is_the_value_normal? }
203 row[:components].each do |pj|
207 pj[:is_normal][k] = (normal.has_key?(k) && normal[k] == for_comparison(v))
213 if params['tab_pane'] == "Graph"
214 provenance, pips = graph(@objects)
216 @pipelines = @objects
219 @prov_svg = ProvenanceHelper::create_provenance_graph provenance, "provenance_svg", {
221 :all_script_parameters => true,
222 :combine_jobs => :script_and_version,
223 :script_version_nodes => true,
228 @object = @objects.first
234 panes = %w(Components Log Graph Advanced)
235 if @object and @object.state.in? ['New', 'Ready']
236 panes = %w(Inputs) + panes - %w(Log)
238 if not @object.components.values.any? { |x| x[:job] rescue false }
244 def compare_pane_list
255 if v.is_a? Hash or v.is_a? Array
262 def find_objects_by_uuid
263 @objects = model_class.where(uuid: params[:uuids])