diff --git a/narps_open/pipelines/team_08MQ.py b/narps_open/pipelines/team_08MQ.py index b31627b1..6d61adf9 100644 --- a/narps_open/pipelines/team_08MQ.py +++ b/narps_open/pipelines/team_08MQ.py @@ -262,6 +262,7 @@ def get_preprocessing(self): ), name = 'remove_func_4') preprocessing = Workflow(base_dir = self.directories.working_dir, name = 'preprocessing') + preprocessing.config['execution']['stop_on_first_crash'] = 'true' preprocessing.connect([ # Inputs (info_source, select_files, [('subject_id', 'subject_id'), ('run_id', 'run_id')]), diff --git a/tests/pipelines/test_team_08MQ.py b/tests/pipelines/test_team_08MQ.py index d062b08c..d3f3d551 100644 --- a/tests/pipelines/test_team_08MQ.py +++ b/tests/pipelines/test_team_08MQ.py @@ -32,7 +32,7 @@ def test_create(): # 2 - check workflows assert isinstance(pipeline.get_preprocessing(), Workflow) - assert pipeline.get_run_level_analysis() is None + assert isinstance(pipeline.get_run_level_analysis(), Workflow) assert isinstance(pipeline.get_subject_level_analysis(), Workflow) group_level = pipeline.get_group_level_analysis() @@ -47,19 +47,19 @@ def test_outputs(): pipeline = PipelineTeam08MQ() # 1 - 1 subject outputs pipeline.subject_list = ['001'] - assert len(pipeline.get_preprocessing_outputs()) == 0 - assert len(pipeline.get_run_level_outputs()) == 0 - assert len(pipeline.get_subject_level_outputs()) == 0 + assert len(pipeline.get_preprocessing_outputs()) == 3*4 + assert len(pipeline.get_run_level_outputs()) == 8+4*3*4 + assert len(pipeline.get_subject_level_outputs()) == 4*3 assert len(pipeline.get_group_level_outputs()) == 0 - assert len(pipeline.get_hypotheses_outputs()) == 0 + assert len(pipeline.get_hypotheses_outputs()) == 18 # 2 - 4 subjects outputs pipeline.subject_list = ['001', '002', '003', '004'] - assert len(pipeline.get_preprocessing_outputs()) == 0 - assert len(pipeline.get_run_level_outputs()) == 0 - assert len(pipeline.get_subject_level_outputs()) == 0 + assert len(pipeline.get_preprocessing_outputs()) == 3*4*4 + assert len(pipeline.get_run_level_outputs()) == (8+4*3*4)*4 + assert len(pipeline.get_subject_level_outputs()) == 4*3*4 assert len(pipeline.get_group_level_outputs()) == 0 - assert len(pipeline.get_hypotheses_outputs()) == 0 + assert len(pipeline.get_hypotheses_outputs()) == 18 @staticmethod @mark.pipeline_test