@@ -45,12 +45,18 @@ def test_phdiff(bids_layouts, tmpdir, output_path, dataset, workdir):
45
45
dsink .interface .out_path_base = 'sdcflows'
46
46
dsink .inputs .source_file = phdiff_files [0 ].path
47
47
48
+ dsink_fmap = pe .Node (DerivativesDataSink (
49
+ base_directory = str (output_path ), keep_dtype = True ), name = 'dsink_fmap' )
50
+ dsink_fmap .interface .out_path_base = 'sdcflows'
51
+ dsink_fmap .inputs .source_file = phdiff_files [0 ].path
52
+
48
53
wf .connect ([
49
54
(phdiff_wf , rep , [
50
55
('outputnode.fmap' , 'fieldmap' ),
51
56
('outputnode.fmap_ref' , 'reference' ),
52
57
('outputnode.fmap_mask' , 'mask' )]),
53
58
(rep , dsink , [('out_report' , 'in_file' )]),
59
+ (phdiff_wf , dsink_fmap , [('outputnode.fmap' , 'in_file' )]),
54
60
])
55
61
else :
56
62
wf .add_nodes ([phdiff_wf ])
@@ -90,12 +96,18 @@ def test_phases(bids_layouts, tmpdir, output_path, workdir):
90
96
dsink .interface .out_path_base = 'sdcflows'
91
97
dsink .inputs .source_file = phdiff_files [0 ].path
92
98
99
+ dsink_fmap = pe .Node (DerivativesDataSink (
100
+ base_directory = str (output_path ), keep_dtype = True ), name = 'dsink_fmap' )
101
+ dsink_fmap .interface .out_path_base = 'sdcflows'
102
+ dsink_fmap .inputs .source_file = phdiff_files [0 ].path
103
+
93
104
wf .connect ([
94
105
(phdiff_wf , rep , [
95
106
('outputnode.fmap' , 'fieldmap' ),
96
107
('outputnode.fmap_ref' , 'reference' ),
97
108
('outputnode.fmap_mask' , 'mask' )]),
98
109
(rep , dsink , [('out_report' , 'in_file' )]),
110
+ (phdiff_wf , dsink_fmap , [('outputnode.fmap' , 'in_file' )]),
99
111
])
100
112
else :
101
113
wf .add_nodes ([phdiff_wf ])
0 commit comments