X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/734335da27f27e2177d3b931b1e5e9e8e83a042f..cf6a9fc619a6c65d2bccb563c61b8a448334213c:/apps/workbench/app/controllers/work_units_controller.rb?ds=sidebyside diff --git a/apps/workbench/app/controllers/work_units_controller.rb b/apps/workbench/app/controllers/work_units_controller.rb index fe6bff1cee..550bdb7e95 100644 --- a/apps/workbench/app/controllers/work_units_controller.rb +++ b/apps/workbench/app/controllers/work_units_controller.rb @@ -14,12 +14,16 @@ class WorkUnitsController < ApplicationController @filters = @filters || [] # get next page of pipeline_instances - filters = @filters + [["uuid", "is_a", ["arvados#pipelineInstance"]]] - pipelines = PipelineInstance.limit(@limit).order(["created_at desc"]).filter(filters) + if PipelineInstance.api_exists?(:index) + filters = @filters + [["uuid", "is_a", ["arvados#pipelineInstance"]]] + pipelines = PipelineInstance.limit(@limit).order(["created_at desc"]).filter(filters) + end # get next page of jobs - filters = @filters + [["uuid", "is_a", ["arvados#job"]]] - jobs = Job.limit(@limit).order(["created_at desc"]).filter(filters) + if Job.api_exists?(:index) + filters = @filters + [["uuid", "is_a", ["arvados#job"]]] + jobs = Job.limit(@limit).order(["created_at desc"]).filter(filters) + end # get next page of container_requests filters = @filters + [["uuid", "is_a", ["arvados#containerRequest"]]] @@ -53,7 +57,7 @@ class WorkUnitsController < ApplicationController workflow = Workflow.find? template_uuid if workflow.definition begin - wf_json = YAML::load(workflow.definition) + wf_json = ActiveSupport::HashWithIndifferentAccess.new YAML::load(workflow.definition) rescue => e logger.error "Error converting definition yaml to json: #{e.message}" raise ArgumentError, "Error converting definition yaml to json: #{e.message}" @@ -73,11 +77,21 @@ class WorkUnitsController < ApplicationController attrs['cwd'] = "/var/spool/cwl" attrs['output_path'] = "/var/spool/cwl" + input_defaults = {} + if wf_json + inputs = get_cwl_inputs(wf_json) + inputs.each do |input| + if input[:default] + input_defaults[cwl_shortname(input[:id])] = input[:default] + end + end + end + # mounts mounts = { "/var/lib/cwl/cwl.input.json" => { "kind" => "json", - "content" => {} + "content" => input_defaults }, "stdout" => { "kind" => "file",