|
4 | 4 | import shutil
|
5 | 5 | from tempfile import mkdtemp
|
6 | 6 |
|
7 |
| -from nipype.testing import assert_equal, assert_true |
| 7 | +import numpy as np |
| 8 | +from nipype.testing import assert_equal, assert_true, assert_raises |
8 | 9 | from nipype.interfaces import utility
|
9 | 10 | import nipype.pipeline.engine as pe
|
10 | 11 |
|
@@ -66,3 +67,49 @@ def increment_array(in_array):
|
66 | 67 | # Clean up
|
67 | 68 | os.chdir(origdir)
|
68 | 69 | shutil.rmtree(tempdir)
|
| 70 | + |
| 71 | + |
| 72 | +def make_random_array(size): |
| 73 | + |
| 74 | + return np.random.randn(size, size) |
| 75 | + |
| 76 | + |
| 77 | +def should_fail(): |
| 78 | + |
| 79 | + tempdir = os.path.realpath(mkdtemp()) |
| 80 | + origdir = os.getcwd() |
| 81 | + os.chdir(tempdir) |
| 82 | + |
| 83 | + node = pe.Node(utility.Function(input_names=["size"], |
| 84 | + output_names=["random_array"], |
| 85 | + function=make_random_array), |
| 86 | + name="should_fail") |
| 87 | + try: |
| 88 | + node.inputs.size = 10 |
| 89 | + node.run() |
| 90 | + finally: |
| 91 | + os.chdir(origdir) |
| 92 | + shutil.rmtree(tempdir) |
| 93 | + |
| 94 | + |
| 95 | +assert_raises(NameError, should_fail) |
| 96 | + |
| 97 | + |
| 98 | +def test_function_with_imports(): |
| 99 | + |
| 100 | + tempdir = os.path.realpath(mkdtemp()) |
| 101 | + origdir = os.getcwd() |
| 102 | + os.chdir(tempdir) |
| 103 | + |
| 104 | + node = pe.Node(utility.Function(input_names=["size"], |
| 105 | + output_names=["random_array"], |
| 106 | + function=make_random_array, |
| 107 | + imports=["import numpy as np"]), |
| 108 | + name="should_not_fail") |
| 109 | + print node.inputs.function_str |
| 110 | + try: |
| 111 | + node.inputs.size = 10 |
| 112 | + node.run() |
| 113 | + finally: |
| 114 | + os.chdir(origdir) |
| 115 | + shutil.rmtree(tempdir) |
0 commit comments