Added mapnode single input test

Updated deprecated  "workflow.config['crashdump_dir']" to
"workflow.config['execution']['crashdump_dir']" in other tests in
test_engine.py

Author: dmordom

nipype/pipeline/tests/test_engine.py

@@ -551,7 +551,7 @@ def func2(a):
     w1.connect(n1, ('a', modify), n2,'a')
     w1.base_dir = wd
 
-    w1.config = {'crashdump_dir': wd}
+    w1.config['execution']['crashdump_dir'] = wd
     # generate outputs
     error_raised = False
     try:
@@ -581,7 +581,7 @@ def func1(in1):
     n1.inputs.in1 = [1]
     w1 = Workflow(name='test')
     w1.base_dir = wd
-    w1.config = {'crashdump_dir': wd}
+    w1.config['execution']['crashdump_dir'] = wd
     w1.add_nodes([n1])
     w1.run()
     n1.inputs.in1 = [2]
@@ -606,3 +606,56 @@ def func1(in1):
     yield assert_false, error_raised
     os.chdir(cwd)
     rmtree(wd)
+
+def test_serial_input():
+    cwd = os.getcwd()
+    wd = mkdtemp()
+    os.chdir(wd)
+    from nipype import MapNode, Function, Workflow
+    def func1(in1):
+        return in1
+    n1 = MapNode(Function(input_names=['in1'],
+                          output_names=['out'],
+                          function=func1),
+                 iterfield=['in1'],
+                 name='n1')
+    n1.inputs.in1 = [1,2,3]
+    
+    
+    w1 = Workflow(name='test')
+    w1.base_dir = wd
+    w1.add_nodes([n1])
+    # set local check
+    w1.config['execution'] = {'stop_on_first_crash': 'true',
+                              'local_hash_check': 'true',
+                              'crashdump_dir': wd}
+    
+    # test output of num_subnodes method when serial is default (False)
+    num_subnodes_default = n1.num_subnodes()
+    yield assert_equal, num_subnodes_default, len(n1.inputs.in1)
+    
+    # test running the workflow on default conditions
+    error_raised = False
+    try:
+        w1.run(plugin='MultiProc')
+    except Exception, e:
+        pe.logger.info('Exception: %s' % str(e))
+        error_raised = True
+    yield assert_false, error_raised
+    
+    # test output of num_subnodes method when serial is True
+    n1._serial=True
+    num_subnodes_serial = n1.num_subnodes()
+    yield assert_equal, num_subnodes_serial, 1
+    
+    # test running the workflow on serial conditions
+    error_raised = False
+    try:
+        w1.run(plugin='MultiProc')
+    except Exception, e:
+        pe.logger.info('Exception: %s' % str(e))
+        error_raised = True
+    yield assert_false, error_raised
+    
+    os.chdir(cwd)
+    rmtree(wd)