Merge pull request #1374 from effigies/ipython_plugin_args

WIP/ENH: Allow client args as IPython plugin_args

Author: satra

nipype/pipeline/plugins/ipython.py

@@ -50,6 +50,11 @@ def __init__(self, plugin_args=None):
         if IPython_not_loaded:
             raise ImportError('Please install ipyparallel to use this plugin.')
         super(IPythonPlugin, self).__init__(plugin_args=plugin_args)
+        valid_args = ('url_file', 'profile', 'cluster_id', 'context', 'debug',
+                      'timeout', 'config', 'username', 'sshserver', 'sshkey',
+                      'password', 'paramiko')
+        self.client_args = {arg: plugin_args[arg]
+                            for arg in valid_args if arg in plugin_args}
         self.iparallel = None
         self.taskclient = None
         self.taskmap = {}
@@ -68,7 +73,7 @@ def run(self, graph, config, updatehash=False):
             raise_from(ImportError("ipyparallel not found. Parallel execution "
                                    "will be unavailable"), e)
         try:
-            self.taskclient = self.iparallel.Client()
+            self.taskclient = self.iparallel.Client(**self.client_args)
         except Exception as e:
             if isinstance(e, TimeoutError):
                 raise_from(Exception("No IPython clients found."), e)