X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/463aed42f5c21b7e347ad13f1ee110feaa7b85a0..f1eb092c311510b60b8c9b00b64407780e2a0302:/apps/workbench/app/controllers/pipeline_instances_controller.rb diff --git a/apps/workbench/app/controllers/pipeline_instances_controller.rb b/apps/workbench/app/controllers/pipeline_instances_controller.rb index 9b31912a48..a618d43517 100644 --- a/apps/workbench/app/controllers/pipeline_instances_controller.rb +++ b/apps/workbench/app/controllers/pipeline_instances_controller.rb @@ -5,11 +5,55 @@ class PipelineInstancesController < ApplicationController include PipelineComponentsHelper def copy - @object = @object.dup + template = PipelineTemplate.find?(@object.pipeline_template_uuid) + + source = @object + @object = PipelineInstance.new + @object.pipeline_template_uuid = source.pipeline_template_uuid + + if params['components'] == 'use_latest' and template + @object.components = template.components.deep_dup + @object.components.each do |cname, component| + # Go through the script parameters of each component + # that are marked as user input and copy them over. + # Skip any components that are not present in the + # source instance (there's nothing to copy) + if source.components.include? cname + component[:script_parameters].each do |pname, val| + if val.is_a? Hash and val[:dataclass] + # this is user-inputtable, so check the value from the source pipeline + srcvalue = source.components[cname][:script_parameters][pname] + if not srcvalue.nil? + component[:script_parameters][pname] = srcvalue + end + end + end + end + end + else + @object.components = source.components.deep_dup + end + + if params['script'] == 'use_same' + # Go through each component and copy the script_version from each job. + @object.components.each do |cname, component| + if source.components.include? cname and source.components[cname][:job] + component[:script_version] = source.components[cname][:job][:script_version] + end + end + end + @object.components.each do |cname, component| component.delete :job end @object.state = 'New' + + # set owner_uuid to that of source, provided it is a project and wriable by current user + current_project = Group.find(source.owner_uuid) rescue nil + if (current_project && current_project.writable_by.andand.include?(current_user.uuid)) + @object.owner_uuid = source.owner_uuid + end + super end