29
29
from nipype .pipeline import engine as pe
30
30
from niworkflows .interfaces .fixes import FixHeaderApplyTransforms as ApplyTransforms
31
31
from niworkflows .utils .images import dseg_label
32
- from smriprep .workflows .outputs import _bids_relative
33
32
34
33
from fmriprep import config
35
34
from fmriprep .config import DEFAULT_MEMORY_MIN_GB
@@ -474,7 +473,6 @@ def init_ds_boldref_wf(
474
473
475
474
def init_ds_boldmask_wf (
476
475
* ,
477
- bids_root ,
478
476
output_dir ,
479
477
desc : str ,
480
478
name = 'ds_boldmask_wf' ,
@@ -488,8 +486,14 @@ def init_ds_boldmask_wf(
488
486
)
489
487
outputnode = pe .Node (niu .IdentityInterface (fields = ['boldmask' ]), name = 'outputnode' )
490
488
491
- raw_sources = pe .Node (niu .Function (function = _bids_relative ), name = 'raw_sources' )
492
- raw_sources .inputs .bids_root = bids_root
489
+ sources = pe .Node (
490
+ BIDSURI (
491
+ numinputs = 1 ,
492
+ dataset_links = config .execution .dataset_links ,
493
+ out_dir = str (config .execution .fmriprep_dir .absolute ()),
494
+ ),
495
+ name = 'sources' ,
496
+ )
493
497
494
498
ds_boldmask = pe .Node (
495
499
DerivativesDataSink (
@@ -504,12 +508,12 @@ def init_ds_boldmask_wf(
504
508
)
505
509
506
510
workflow .connect ([
507
- (inputnode , raw_sources , [('source_files' , 'in_files ' )]),
511
+ (inputnode , sources , [('source_files' , 'in1 ' )]),
508
512
(inputnode , ds_boldmask , [
509
513
('boldmask' , 'in_file' ),
510
514
('source_files' , 'source_file' ),
511
515
]),
512
- (raw_sources , ds_boldmask , [('out' , 'RawSources ' )]),
516
+ (sources , ds_boldmask , [('out' , 'Sources ' )]),
513
517
(ds_boldmask , outputnode , [('out_file' , 'boldmask' )]),
514
518
]) # fmt:skip
515
519
0 commit comments