@@ -599,26 +599,14 @@ def init_wb_vol_surf_wf(
599
599
iterables = [('hemi' , ['L' , 'R' ])],
600
600
)
601
601
602
- joinnode = pe .JoinNode (
603
- niu .IdentityInterface (fields = ['bold_fsnative' ]),
604
- name = 'joinnode_vol_surf' ,
605
- joinsource = 'hemisource_vol_surf' ,
606
- )
607
-
608
- outputnode = pe .Node (
602
+ outputnode = pe .JoinNode (
609
603
niu .IdentityInterface (fields = ['bold_fsnative' ]),
610
604
name = 'outputnode' ,
605
+ joinsource = 'hemisource_vol_surf' ,
611
606
)
612
607
613
608
select_surfaces = pe .Node (
614
- KeySelect (
615
- fields = [
616
- 'white' ,
617
- 'pial' ,
618
- 'midthickness' ,
619
- ],
620
- keys = ['L' , 'R' ],
621
- ),
609
+ KeySelect (fields = ['white' , 'pial' , 'midthickness' ], keys = ['L' , 'R' ]),
622
610
name = 'select_surfaces' ,
623
611
run_without_submitting = True ,
624
612
)
@@ -630,13 +618,6 @@ def init_wb_vol_surf_wf(
630
618
n_procs = omp_nthreads ,
631
619
)
632
620
633
- metric_dilate = pe .Node (
634
- MetricDilate (distance = 10 , nearest = True ),
635
- name = 'metric_dilate' ,
636
- mem_gb = 1 ,
637
- n_procs = omp_nthreads ,
638
- )
639
-
640
621
workflow .connect ([
641
622
(inputnode , select_surfaces , [
642
623
('white' , 'white' ),
@@ -653,17 +634,23 @@ def init_wb_vol_surf_wf(
653
634
('white' , 'inner_surface' ),
654
635
('pial' , 'outer_surface' ),
655
636
]),
656
- (joinnode , outputnode , [('bold_fsnative' , 'bold_fsnative' )]),
657
637
]) # fmt:skip
658
638
659
639
if dilate :
640
+ metric_dilate = pe .Node (
641
+ MetricDilate (distance = 10 , nearest = True ),
642
+ name = 'metric_dilate' ,
643
+ mem_gb = 1 ,
644
+ n_procs = omp_nthreads ,
645
+ )
646
+
660
647
workflow .connect ([
661
648
(select_surfaces , metric_dilate , [('midthickness' , 'surf_file' )]),
662
649
(volume_to_surface , metric_dilate , [('out_file' , 'in_file' )]),
663
- (metric_dilate , joinnode , [('out_file' , 'bold_fsnative' )]),
650
+ (metric_dilate , outputnode , [('out_file' , 'bold_fsnative' )]),
664
651
]) # fmt:skip
665
652
else :
666
- workflow .connect (volume_to_surface , 'out_file' , joinnode , 'bold_fsnative' )
653
+ workflow .connect (volume_to_surface , 'out_file' , outputnode , 'bold_fsnative' )
667
654
668
655
return workflow
669
656
@@ -761,15 +748,10 @@ def init_wb_surf_surf_wf(
761
748
iterables = [('hemi' , ['L' , 'R' ])],
762
749
)
763
750
764
- joinnode = pe .JoinNode (
765
- niu .IdentityInterface (fields = ['bold_resampled' ]),
766
- name = f'joinnode_surf_surf_{ template } _{ density } ' ,
767
- joinsource = f'hemisource_surf_surf_{ template } _{ density } ' ,
768
- )
769
-
770
- outputnode = pe .Node (
751
+ outputnode = pe .JoinNode (
771
752
niu .IdentityInterface (fields = ['bold_resampled' ]),
772
753
name = 'outputnode' ,
754
+ joinsource = f'hemisource_surf_surf_{ template } _{ density } ' ,
773
755
)
774
756
775
757
select_surfaces = pe .Node (
@@ -819,12 +801,9 @@ def init_wb_surf_surf_wf(
819
801
('midthickness' , 'current_area' ),
820
802
('midthickness_resampled' , 'new_area' ),
821
803
]),
822
- (resample_to_template , joinnode , [
804
+ (resample_to_template , outputnode , [
823
805
('out_file' , 'bold_resampled' ),
824
806
]),
825
- (joinnode , outputnode , [
826
- ('bold_resampled' , 'bold_resampled' ),
827
- ]),
828
807
]) # fmt:skip
829
808
830
809
return workflow
0 commit comments