Skip to content

Commit 54aa6ad

Browse files
Apply suggestions from code review
Co-authored-by: Chris Markiewicz <[email protected]>
1 parent 49685aa commit 54aa6ad

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

nipype/pipeline/engine/utils.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1115,10 +1115,8 @@ def make_field_func(*pair):
11151115
# Non-IdentityInterface w/ iterables
11161116
# - src_idJ\d+ : JoinNode(IdentityInterface)
11171117
if itername.startswith(src_id):
1118-
itername = itername[len(src_id):]
1119-
if re.fullmatch(
1120-
r"((\.[a-z](I\.[a-z])?|J)\d+)?", itername
1121-
):
1118+
suffix = itername[len(src_id):]
1119+
if re.fullmatch(r"((\.[a-z](I\.[a-z])?|J)\d+)?", suffix):
11221120
expansions[src_id].append(node)
11231121
for in_id, in_nodes in list(expansions.items()):
11241122
logger.debug(

nipype/pipeline/engine/workflows.py

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -913,11 +913,9 @@ def _set_node_input(self, node, param, source, sourceinfo):
913913
node.set_input(param, deepcopy(newval))
914914

915915
def _get_all_nodes(self):
916-
allnodes = [
917-
*self._nodes_cache.difference(self._nested_workflows_cache)
918-
] # all nodes that are not workflows
916+
allnodes = self._nodes_cache - self._nested_workflows_cache
919917
for node in self._nested_workflows_cache:
920-
allnodes.extend(node._get_all_nodes())
918+
allnodes |= node._get_all_nodes()
921919
return allnodes
922920

923921
def _update_node_cache(self):

0 commit comments

Comments
 (0)