@@ -19,23 +19,27 @@ def test_create_eddy_correct_pipeline():
19
19
fsl_course_dir = os .path .abspath (os .environ ['FSL_COURSE_DATA' ])
20
20
21
21
dwi_file = os .path .join (fsl_course_dir , "fdt1/subj1/data.nii.gz" )
22
+
23
+ trim_dwi = pe .Node (fsl .ExtractROI (t_min = 0 ,
24
+ t_size = 3 ), name = "trim_dwi" )
25
+ trim_dwi .inputs .in_file = dwi_file
22
26
23
27
nipype_eddycorrect = create_eddy_correct_pipeline ("nipype_eddycorrect" )
24
- nipype_eddycorrect .inputs .inputnode .in_file = dwi_file
25
28
nipype_eddycorrect .inputs .inputnode .ref_num = 0
26
29
27
30
with warnings .catch_warnings ():
28
31
warnings .simplefilter ("ignore" )
29
32
original_eddycorrect = pe .Node (interface = fsl .EddyCorrect (), name = "original_eddycorrect" )
30
- original_eddycorrect .inputs .in_file = dwi_file
31
33
original_eddycorrect .inputs .ref_num = 0
32
34
33
35
test = pe .Node (util .AssertEqual (), name = "eddy_corrected_dwi_test" )
34
36
35
37
pipeline = pe .Workflow (name = "test_eddycorrect" )
36
38
pipeline .base_dir = tempfile .mkdtemp (prefix = "nipype_test_eddycorrect_" )
37
39
38
- pipeline .connect ([(nipype_eddycorrect , test , [("outputnode.eddy_corrected" , "volume1" )]),
40
+ pipeline .connect ([(trim_dwi , original_eddycorrect , [("roi_file" , "in_file" )]),
41
+ (trim_dwi , nipype_eddycorrect , [("roi_file" , "inputnode.in_file" )]),
42
+ (nipype_eddycorrect , test , [("outputnode.eddy_corrected" , "volume1" )]),
39
43
(original_eddycorrect , test , [("eddy_corrected" , "volume2" )]),
40
44
])
41
45
0 commit comments