Skip to content
Snippets Groups Projects
Commit d6ce280e authored by aknecht2's avatar aknecht2
Browse files

Added 'list' argument to allow vararg inputs. Updated workflow_module & job...

Added 'list' argument to allow vararg inputs. Updated workflow_module & job accordingly to handle new input type.
parent 8d9f4c72
Branches
Tags
No related merge requests found
...@@ -85,9 +85,12 @@ resources = { ...@@ -85,9 +85,12 @@ resources = {
# file -> Normal file arguments. # file -> Normal file arguments.
# stdout -> Any file argument that is redirected from stdout # stdout -> Any file argument that is redirected from stdout
# stderr -> Any file argument that is redirected from stderr # stderr -> Any file argument that is redirected from stderr
# list -> For variable argument inputs
# list -> Currently a list of files.
argument_types = { argument_types = {
"argument": ["string", "numeric"], "argument": ["string", "numeric"],
"file": ["file", "rawfile", "stdout", "stderr"] "file": ["file", "rawfile", "stdout", "stderr"],
"list": ["list"]
} }
# Defines information about arguments # Defines information about arguments
......
...@@ -396,6 +396,15 @@ class WorkflowModule(object): ...@@ -396,6 +396,15 @@ class WorkflowModule(object):
"file": master_files[arg_params[param_name]], "file": master_files[arg_params[param_name]],
"type": param_info["type"] "type": param_info["type"]
}) })
elif param_info["type"] in chipathlon.conf.argument_types["list"]:
sub_list = []
for val in arg_params[param_name]:
sub_list.append({
"name": val,
"file": master_files[val],
"type": "file"
})
param_list.append({"name": arg_params[param_name], "type": "list", "value": sub_list})
else: else:
param_list.append({ param_list.append({
"name": param_name, "name": param_name,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment