diff --git a/src/nextflow_file.py b/src/nextflow_file.py index f23e39a8a9598a589269b1a6d9c2a54ed735b6c6..ca7d93c5780d1dcf0e24c75f19eb06abe843a4f8 100644 --- a/src/nextflow_file.py +++ b/src/nextflow_file.py @@ -296,11 +296,13 @@ class Nextflow_File(Nextflow_Building_Blocks): raise Exception(f"Process '{name}' couldn't be found in '{self.get_file_address()}'") - def get_processes_defined(self, tab = []): - tab+= super().get_processes() + def get_processes_defined(self, dict = {}): + processes = self.get_processes() + for p in processes: + dict[p] = [] for include in self.includes: - tab+=include.get_file().get_processes_defined() - return list(set(tab)) + _ = include.get_file().get_processes_defined(dict = dict) + return dict def get_processes_called(self, tab = []): diff --git a/src/workflow.py b/src/workflow.py index e1914c64a4edc207e41599220a1e2f90d8c77c70..3d2021d453020dadecd3ebe55cafc126fcee8f29 100644 --- a/src/workflow.py +++ b/src/workflow.py @@ -225,7 +225,8 @@ class Workflow: self.nextflow_file.add_2_rocrate(dico) def get_processes_defined(self): - return self.nextflow_file.get_processes_defined() + processes = self.nextflow_file.get_processes_defined(dict={}).keys() + return list(processes) def get_processes_called(self): return self.nextflow_file.get_processes_called()