File tree Expand file tree Collapse file tree 5 files changed +9
-7
lines changed Expand file tree Collapse file tree 5 files changed +9
-7
lines changed Original file line number Diff line number Diff line change 77from nose .tools import assert_equal
88
99from .. import Memory
10- from ...pipeline .tests .test_engine import TestInterface
10+ from ...pipeline .engine . tests .test_engine import TestInterface
1111
1212from ... import config
1313config .set_default_config ()
Original file line number Diff line number Diff line change 1111__docformat__ = 'restructuredtext'
1212from .workflows import Workflow
1313from .nodes import Node , MapNode , JoinNode
14+ from .utils import generate_expanded_graph
Original file line number Diff line number Diff line change @@ -75,7 +75,7 @@ def fullname(self):
7575 return fullname
7676
7777 def clone (self , name ):
78- """Clone a workflowbase object
78+ """Clone an EngineBase object
7979
8080 Parameters
8181 ----------
Original file line number Diff line number Diff line change @@ -540,7 +540,8 @@ def func1(in1):
540540 try :
541541 n2 .run ()
542542 except Exception as e :
543- pe .logger .info ('Exception: %s' % str (e ))
543+ from nipype .pipeline .engine .base import logger
544+ logger .info ('Exception: %s' % str (e ))
544545 error_raised = True
545546 yield assert_true , error_raised
546547
Original file line number Diff line number Diff line change @@ -326,7 +326,7 @@ def add_nodes(self, nodes):
326326 Parameters
327327 ----------
328328 nodes : list
329- A list of WorkflowBase -based objects
329+ A list of EngineBase -based objects
330330 """
331331 newnodes = []
332332 all_nodes = self ._get_all_nodes ()
@@ -343,8 +343,8 @@ def add_nodes(self, nodes):
343343 logger .debug ('no new nodes to add' )
344344 return
345345 for node in newnodes :
346- if not issubclass (node .__class__ , WorkflowBase ):
347- raise Exception ('Node %s must be a subclass of WorkflowBase ' %
346+ if not issubclass (node .__class__ , EngineBase ):
347+ raise Exception ('Node %s must be a subclass of EngineBase ' %
348348 str (node ))
349349 self ._check_nodes (newnodes )
350350 for node in newnodes :
@@ -358,7 +358,7 @@ def remove_nodes(self, nodes):
358358 Parameters
359359 ----------
360360 nodes : list
361- A list of WorkflowBase -based objects
361+ A list of EngineBase -based objects
362362 """
363363 self ._graph .remove_nodes_from (nodes )
364364
You can’t perform that action at this time.
0 commit comments