Skip to content

fix: closes #1920 to revert to original behavior for input names #1937

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 5 commits into from
Apr 5, 2017
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
46 changes: 36 additions & 10 deletions nipype/interfaces/utility/base.py
Original file line number Diff line number Diff line change
Expand Up @@ -99,13 +99,29 @@ def _list_outputs(self):
class MergeInputSpec(DynamicTraitedSpec, BaseInterfaceInputSpec):
axis = traits.Enum('vstack', 'hstack', usedefault=True,
desc='direction in which to merge, hstack requires same number of elements in each input')
no_flatten = traits.Bool(False, usedefault=True, desc='append to outlist instead of extending in vstack mode')
no_flatten = traits.Bool(False, usedefault=True,
desc='append to outlist instead of extending in vstack mode')
ravel_inputs = traits.Bool(False, usedefault=True,
desc='ravel inputs when no_flatten is False')


class MergeOutputSpec(TraitedSpec):
out = traits.List(desc='Merged output')


def _ravel(in_val):
if not isinstance(in_val, list):
return in_val
flat_list = []
for val in in_val:
raveled_val = _ravel(val)
if isinstance(raveled_val, list):
flat_list.extend(raveled_val)
else:
flat_list.append(raveled_val)
return flat_list


class Merge(IOBase):
"""Basic interface class to merge inputs into a single list

Expand All @@ -123,23 +139,34 @@ class Merge(IOBase):
>>> out.outputs.out
[1, 2, 5, 3]

>>> merge = Merge() # Or Merge(1)
>>> merge.inputs.in_lists = [1, [2, 5], 3]
>>> merge = Merge(1)
>>> merge.inputs.in1 = [1, [2, 5], 3]
>>> out = merge.run()
>>> out.outputs.out
[1, [2, 5], 3]

>>> merge = Merge(1)
>>> merge.inputs.in1 = [1, [2, 5], 3]
>>> merge.inputs.ravel_inputs = True
>>> out = merge.run()
>>> out.outputs.out
[1, 2, 5, 3]

>>> merge = Merge(1)
>>> merge.inputs.in1 = [1, [2, 5], 3]
>>> merge.inputs.no_flatten = True
>>> out = merge.run()
>>> out.outputs.out
[[1, [2, 5], 3]]
"""
input_spec = MergeInputSpec
output_spec = MergeOutputSpec

def __init__(self, numinputs=1, **inputs):
def __init__(self, numinputs=0, **inputs):
super(Merge, self).__init__(**inputs)
self._numinputs = numinputs
if numinputs > 1:
if numinputs >= 1:
input_names = ['in%d' % (i + 1) for i in range(numinputs)]
elif numinputs == 1:
input_names = ['in_lists']
else:
input_names = []
add_traits(self.inputs, input_names)
Expand All @@ -150,8 +177,6 @@ def _list_outputs(self):

if self._numinputs < 1:
return outputs
elif self._numinputs == 1:
values = self.inputs.in_lists
else:
getval = lambda idx: getattr(self.inputs, 'in%d' % (idx + 1))
values = [getval(idx) for idx in range(self._numinputs)
Expand All @@ -160,7 +185,8 @@ def _list_outputs(self):
if self.inputs.axis == 'vstack':
for value in values:
if isinstance(value, list) and not self.inputs.no_flatten:
out.extend(value)
out.extend(_ravel(value) if self.inputs.ravel_inputs else
value)
else:
out.append(value)
else:
Expand Down
11 changes: 3 additions & 8 deletions nipype/interfaces/utility/tests/test_base.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,25 +56,20 @@ def test_split(tmpdir, args, expected):
([3], {}, [0, [1, 2], [3, 4, 5]], [0, 1, 2, 3, 4, 5]),
([0], {}, None, None),
([], {}, [], []),
([], {}, [0, [1, 2], [3, 4, 5]], [0, 1, 2, 3, 4, 5]),
([], {}, [0, [1, 2], [3, 4, 5]], [0, [1, 2], [3, 4, 5]]),
([3], {'axis': 'hstack'}, [[0], [1, 2], [3, 4, 5]], [[0, 1, 3]]),
([3], {'axis': 'hstack'}, [[0, 1], [2, 3], [4, 5]],
[[0, 2, 4], [1, 3, 5]]),
([3], {'axis': 'hstack'}, [[0, 1], [2, 3], [4, 5]],
[[0, 2, 4], [1, 3, 5]]),
([1], {'axis': 'hstack'}, [[0], [1, 2], [3, 4, 5]], [[0, 1, 3]]),
([1], {'axis': 'hstack'}, [[0, 1], [2, 3], [4, 5]],
[[0, 2, 4], [1, 3, 5]]),
])
def test_merge(tmpdir, args, kwargs, in_lists, expected):
os.chdir(str(tmpdir))

node = pe.Node(utility.Merge(*args, **kwargs), name='merge')

numinputs = args[0] if args else 1
if numinputs == 1:
node.inputs.in_lists = in_lists
elif numinputs > 1:
numinputs = args[0] if args else 0
if numinputs >= 1:
for i in range(1, numinputs + 1):
setattr(node.inputs, 'in{:d}'.format(i), in_lists[i - 1])

Expand Down