@@ -367,34 +367,24 @@ def init_single_subject_wf(subject_id):
367
367
use_bbr = True ,
368
368
)
369
369
370
- workflow .connect (
371
- [
372
- # T1w Mask
373
- (
374
- anat_preproc_wf ,
375
- t1w_brain ,
376
- [
377
- ("outputnode.t1w_preproc" , "in_file" ),
378
- ("outputnode.t1w_mask" , "in_mask" ),
379
- ],
380
- ),
381
- # BBRegister
382
- (split_info , bbr_wf , [("dwi_file" , "inputnode.in_file" )]),
383
- (t1w_brain , bbr_wf , [("out_file" , "inputnode.t1w_brain" )]),
384
- (
385
- anat_preproc_wf ,
386
- bbr_wf ,
387
- [("outputnode.t1w_dseg" , "inputnode.t1w_dseg" )],
388
- ),
389
- (fsinputnode , bbr_wf , [("subjects_dir" , "inputnode.subjects_dir" )]),
390
- (bids_info , bbr_wf , [("subject" , "inputnode.subject_id" )]),
391
- (
392
- anat_preproc_wf ,
393
- bbr_wf ,
394
- [("outputnode.fsnative2t1w_xfm" , "inputnode.fsnative2t1w_xfm" )],
395
- ),
396
- ]
397
- )
370
+ # fmt:off
371
+ workflow .connect ([
372
+ # T1w Mask
373
+ (anat_preproc_wf , t1w_brain , [
374
+ ("outputnode.t1w_preproc" , "in_file" ),
375
+ ("outputnode.t1w_mask" , "in_mask" ),
376
+ ]),
377
+ # BBRegister
378
+ (split_info , bbr_wf , [("dwi_file" , "inputnode.in_file" )]),
379
+ (t1w_brain , bbr_wf , [("out_file" , "inputnode.t1w_brain" )]),
380
+ (anat_preproc_wf , bbr_wf , [("outputnode.t1w_dseg" , "inputnode.t1w_dseg" )]),
381
+ (fsinputnode , bbr_wf , [("subjects_dir" , "inputnode.subjects_dir" )]),
382
+ (bids_info , bbr_wf , [("subject" , "inputnode.subject_id" )]),
383
+ (anat_preproc_wf , bbr_wf , [
384
+ ("outputnode.fsnative2t1w_xfm" , "inputnode.fsnative2t1w_xfm" )
385
+ ]),
386
+ ])
387
+ # fmt:on
398
388
399
389
fmap_estimation_wf = init_fmap_estimation_wf (
400
390
subject_data ["dwi" ], debug = config .execution .debug
0 commit comments