Commit 88038486 authored by Jerome Mariette's avatar Jerome Mariette
Browse files

No commit message

No commit message
parent 020a6d58
...@@ -840,7 +840,7 @@ class InputFileList(ParameterList, AbstractInputFile): ...@@ -840,7 +840,7 @@ class InputFileList(ParameterList, AbstractInputFile):
return create_test_function(ctype) return create_test_function(ctype)
def prepare_input_files(self, inputs): def prepare_input_files(self, inputs):
path2test = inputs path2test = _copy.deepcopy(inputs)
if not path2test.__class__.__name__ == "list": if not path2test.__class__.__name__ == "list":
path2test = [path2test] path2test = [path2test]
new_vals, done = [], [] new_vals, done = [], []
......
...@@ -83,6 +83,7 @@ class Workflow(threading.Thread): ...@@ -83,6 +83,7 @@ class Workflow(threading.Thread):
self.end_time = None self.end_time = None
self.step = None self.step = None
self.stderr = None self.stderr = None
self.args = args
self.dynamic_component_present = False self.dynamic_component_present = False
self.__to_address = None self.__to_address = None
self.__subject = None self.__subject = None
...@@ -111,9 +112,7 @@ class Workflow(threading.Thread): ...@@ -111,9 +112,7 @@ class Workflow(threading.Thread):
self.define_parameters(self.function) self.define_parameters(self.function)
# add the metadata parameter # add the metadata parameter
self.add_parameter_list("metadata", "Which metadata should be linked to this workflow") self.add_parameter_list("metadata", "Which metadata should be linked to this workflow")
# if some args are provided, let's fill the parameters
if args: self._set_parameters(args)
if self.id is not None: if self.id is not None:
self.directory = self.manager.get_workflow_directory(self.name, self.id) self.directory = self.manager.get_workflow_directory(self.name, self.id)
if not os.path.isdir(self.directory): if not os.path.isdir(self.directory):
...@@ -638,6 +637,8 @@ class Workflow(threading.Thread): ...@@ -638,6 +637,8 @@ class Workflow(threading.Thread):
self.step = 0 self.step = 0
self.status = self.STATUS_STARTED self.status = self.STATUS_STARTED
self.end_time = None self.end_time = None
# if some args are provided, let's fill the parameters
self._set_parameters(self.args)
self._serialize() self._serialize()
# if pre_processing has not been done yet # if pre_processing has not been done yet
if self.step == 0: if self.step == 0:
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment