Skip to content

Commit 54718c7

Browse files
committed
[FIX] MapNodes failed when MultiProcPlugin passed by instance
When calling ``workflow.run(plugin=MultiProcPlugin())``, MapNodes are set the ``use_plugin`` member that is not pickleable if ``plugin`` is a ``MultiProcPlugin`` object.
1 parent ffb8a16 commit 54718c7

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

nipype/pipeline/engine/workflows.py

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -566,6 +566,8 @@ def run(self, plugin=None, plugin_args=None, updatehash=False):
566566
plugin = config.get('execution', 'plugin')
567567
if not isinstance(plugin, (str, bytes)):
568568
runner = plugin
569+
plugin = runner.__class__.__name__[:-len('Plugin')]
570+
plugin_args = runner.plugin_args
569571
else:
570572
name = '.'.join(__name__.split('.')[:-2] + ['plugins'])
571573
try:

0 commit comments

Comments
 (0)