added group_id to pipeline names

Author: chrisgorgo

nipype/workflows/dmri/camino/group_connectivity.py

@@ -74,7 +74,7 @@ def create_group_connectivity_pipeline(group_list, group_id, data_dir, subjects_
     datasink.inputs.base_directory = output_dir
     datasink.inputs.container = group_id
 
-    l1pipeline = pe.Workflow(name="l1pipeline")
+    l1pipeline = pe.Workflow(name="l1pipeline_"+group_id)
     l1pipeline.base_dir = output_dir
     l1pipeline.base_output_dir = group_id
     l1pipeline.connect([(subj_infosource, datasource,[('subject_id', 'subject_id')])])

nipype/workflows/dmri/connectivity/group_connectivity.py

@@ -112,7 +112,7 @@ def create_merge_networks_by_group_workflow(group_list, group_id, data_dir, subj
     l2datasink.inputs.base_directory = output_dir
     l2datasink.inputs.container = group_id
 
-    l2pipeline = pe.Workflow(name="l2output")
+    l2pipeline = pe.Workflow(name="l2output_"+group_id)
     l2pipeline.base_dir = op.join(output_dir, 'l2output')
     l2pipeline.connect([(group_infosource, l2infosource,[('group_id','group_id')])])
 
@@ -181,7 +181,7 @@ def create_merge_network_results_by_group_workflow(group_list, group_id, data_di
     l2datasink.inputs.base_directory = output_dir
     l2datasink.inputs.container = group_id
 
-    l2pipeline = pe.Workflow(name="l2output")
+    l2pipeline = pe.Workflow(name="l2output_"+group_id)
     l2pipeline.base_dir = op.join(output_dir, 'l2output')
     l2pipeline.connect([(group_infosource, l2infosource,[('group_id','group_id')])])
 

nipype/workflows/dmri/mrtrix/group_connectivity.py

@@ -90,7 +90,7 @@ def create_group_connectivity_pipeline(group_list, group_id, data_dir, subjects_
     datasink.inputs.base_directory = output_dir
     datasink.inputs.container = group_id
 
-    l1pipeline = pe.Workflow(name="l1pipeline")
+    l1pipeline = pe.Workflow(name="l1pipeline_"+group_id)
     l1pipeline.base_dir = output_dir
     l1pipeline.base_output_dir = group_id
     l1pipeline.connect([(subj_infosource, conmapper,[('subject_id', 'inputnode.subject_id')])])