diff --git a/narps_open/pipelines/team_08MQ.py b/narps_open/pipelines/team_08MQ.py index 3337a0fd..cabea294 100644 --- a/narps_open/pipelines/team_08MQ.py +++ b/narps_open/pipelines/team_08MQ.py @@ -261,10 +261,6 @@ def get_preprocessing(self): output_names = [] ), name = 'remove_func_4') - # Merge Node - Merge the output triggers for remove_func_1 Node - # i.e: slice_time_corrected_file is needed by two Nodes before being removed - merge_removal_triggers = Node(Merge(2), name = 'merge_removal_triggers') - preprocessing = Workflow(base_dir = self.directories.working_dir, name = 'preprocessing') preprocessing.config['execution']['stop_on_first_crash'] = 'true' preprocessing.connect([ @@ -325,15 +321,13 @@ def get_preprocessing(self): # File removals (motion_correction, remove_func_0, [('out_file', 'files')]), - (slice_time_correction, remove_func_0, [('slice_time_corrected_file', '_')]), + (data_sink, remove_func_0, [('out_file', '_')]), (slice_time_correction, remove_func_1, [('slice_time_corrected_file', 'files')]), - (smoothing, merge_removal_triggers, [('smoothed_file', 'in1')]), - (compute_confounds, merge_removal_triggers, [('components_file', 'in2')]), - (merge_removal_triggers, remove_func_1, [('out', '_')]), + (data_sink, remove_func_1, [('out_file', '_')]), (smoothing, remove_func_2, [('smoothed_file', 'files')]), - (alignment_func_to_anat, remove_func_2, [('out_file', '_')]), + (data_sink, remove_func_2, [('out_file', '_')]), (alignment_func_to_anat, remove_func_3, [('out_file', 'files')]), - (alignment_func_to_mni, remove_func_3, [('output_image', '_')]), + (data_sink, remove_func_3, [('out_file', '_')]), (alignment_func_to_mni, remove_func_4, [('output_image', 'files')]), (data_sink, remove_func_4, [('out_file', '_')]) ])