From 8770d81f75b45935168c3539159d1a014dd89c06 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Boris=20Cl=C3=A9net?= Date: Fri, 27 Oct 2023 09:36:35 +0200 Subject: [PATCH] Deletinglarge files after datasink --- narps_open/pipelines/team_08MQ.py | 14 ++++---------- 1 file changed, 4 insertions(+), 10 deletions(-) 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', '_')]) ])