Bug fix (in case of unknown program/args for a task)

Author: henricasanova

wfcommons/wfinstances/logs/snakemake.py

@@ -214,23 +214,29 @@ def _create_tasks(self):
 
             if self.task_shell[idx]:
                 program_name = self.task_shell[idx].split(' ')[0]
-                # program_args = self.task_shell[idx].split(' ')[0:]
                 program_args = shlex.split(self.task_shell[idx], posix=False)
+                task = Task(name=self.task_map[idx],
+                            task_id=self.task_map[idx],
+                            task_type=TaskType.COMPUTE,
+                            runtime=elapsed,
+                            executed_at=start_date,
+                            input_files=input_files,
+                            output_files=output_files,
+                            program=program_name,
+                            cores=self.task_threads[idx],
+                            args=program_args,
+                            logger=self.logger)
             else:
-                program_name = "n/a"
-                program_args = []
-
-            task = Task(name=self.task_map[idx],
-                        task_id=self.task_map[idx],
-                        task_type=TaskType.COMPUTE,
-                        runtime=elapsed,
-                        executed_at=start_date,
-                        input_files=input_files,
-                        output_files=output_files,
-                        program=program_name,
-                        cores=self.task_threads[idx],
-                        args=program_args,
-                        logger=self.logger)
+                task = Task(name=self.task_map[idx],
+                            task_id=self.task_map[idx],
+                            task_type=TaskType.COMPUTE,
+                            runtime=elapsed,
+                            executed_at=start_date,
+                            input_files=input_files,
+                            output_files=output_files,
+                            cores=self.task_threads[idx],
+                            logger=self.logger)
+
             self.workflow.add_task(task)
 
         # File dependencies