Connect the download volumes nodes.

ohsu-qin · Jun 20, 2017 · 2dec8e1 · 2dec8e1
1 parent c6d44f9
commit 2dec8e1
Showing 1 changed file with 6 additions and 7 deletions.
diff --git a/qipipe/pipeline/qipipeline.py b/qipipe/pipeline/qipipeline.py
@@ -846,16 +846,15 @@ def _create_workflow(self, subject, session, scan, actions, **opts):
                 dl_vols_xfc = XNATDownload(project=self.project,
                                            resource='NIFTI',
                                            file='volume*.nii.gz')
-                dl_vols_node = pe.Node(dl_vols_xfc,
-                                       name='download_scan_volumes')
-                exec_wf.connect(input_spec, 'subject', dl_vols_node, 'subject')
-                exec_wf.connect(input_spec, 'session', dl_vols_node, 'session')
-                exec_wf.connect(input_spec, 'scan', dl_vols_node, 'scan')
+                dl_vols = pe.Node(dl_vols_xfc, name='download_scan_volumes')
+                exec_wf.connect(input_spec, 'subject', dl_vols, 'subject')
+                exec_wf.connect(input_spec, 'session', dl_vols, 'session')
+                exec_wf.connect(input_spec, 'scan', dl_vols, 'scan')
                 # Rename the download out_file to volume_files.
                 scan_volumes_xfc = IdentityInterface(fields=['volume_files'])
                 scan_volumes = pe.Node(scan_volumes_xfc, name='scan_volumes')
-                exec_wf.connect(dl_vols_node, 'out_files',
-                                dl_vols_node, 'volume_files')
+                exec_wf.connect(dl_vols, 'out_files',
+                                scan_volumes, 'volume_files')
 
         # Registration and modeling require a mask and bolus arrival.
         if mask_node: