Skip to content
Snippets Groups Projects
Commit c2fde659 authored by George Marchment's avatar George Marchment
Browse files

check if the relevant processes exist in workflow

parent 2cb08b6b
No related branches found
No related tags found
No related merge requests found
Pipeline #14116 passed with stage
in 2 minutes and 19 seconds
...@@ -42,6 +42,7 @@ class BioFlowInsightError(Exception): ...@@ -42,6 +42,7 @@ class BioFlowInsightError(Exception):
#* [18] -> something is expected to be defined in a file but is not #* [18] -> something is expected to be defined in a file but is not
#* [20] -> The sibworkflow either emits nothing or to many values for a use in an operation #* [20] -> The sibworkflow either emits nothing or to many values for a use in an operation
#* [22] -> a subworkflow or process defined was defined badly #* [22] -> a subworkflow or process defined was defined badly
#* [24] -> The user gives a relevant process which isn't in the workflow
######################## ########################
......
...@@ -543,6 +543,13 @@ George Marchment, Bryan Brancotte, Marie Schmit, Frédéric Lemoine, Sarah Cohen ...@@ -543,6 +543,13 @@ George Marchment, Bryan Brancotte, Marie Schmit, Frédéric Lemoine, Sarah Cohen
self.nextflow_file.generate_process_dependency_graph(render_graphs = render_graphs, processes_2_remove = self.tab_processes_2_remove) self.nextflow_file.generate_process_dependency_graph(render_graphs = render_graphs, processes_2_remove = self.tab_processes_2_remove)
def generate_user_view(self, relevant_processes = [], render_graphs = True): def generate_user_view(self, relevant_processes = [], render_graphs = True):
#Check all relevat processes are in wf
workflow_processes = []
for p in self.get_processes_called():
workflow_processes.append(p.get_name())
for p in relevant_processes:
if(p not in workflow_processes):
raise BioFlowInsightError(f"Process {p} given in relevant processes is not present in the workflow's processes", 24)
self.iniatilise_tab_processes_2_remove() self.iniatilise_tab_processes_2_remove()
self.nextflow_file.generate_user_view(relevant_processes = relevant_processes, render_graphs = render_graphs, processes_2_remove = self.tab_processes_2_remove) self.nextflow_file.generate_user_view(relevant_processes = relevant_processes, render_graphs = render_graphs, processes_2_remove = self.tab_processes_2_remove)
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment