fix: improve version checking for nodes of workflows

Author: satra

nipype/__init__.py

@@ -14,11 +14,7 @@
 import os
 from distutils.version import LooseVersion
 
-from .info import (
-    URL as __url__,
-    STATUS as __status__,
-    __version__,
-)
+from .info import URL as __url__, STATUS as __status__, __version__
 from .utils.config import NipypeConfig
 from .utils.logger import Logging
 from .refs import due
@@ -105,6 +101,8 @@ def check_latest_version(raise_exception=False):
                         packname="nipype", version=__version__, latest=latest["version"]
                     )
                 )
+            else:
+                logger.info("No new version available.")
             if latest["bad_versions"] and any(
                 [
                     LooseVersion(__version__) == LooseVersion(ver)

nipype/pipeline/plugins/multiproc.py

@@ -10,7 +10,7 @@
 # Import packages
 import os
 import multiprocessing as mp
-from concurrent.futures import ProcessPoolExecutor
+from concurrent.futures import ProcessPoolExecutor, wait
 from traceback import format_exception
 import sys
 from logging import INFO
@@ -73,6 +73,12 @@ def run_node(node, updatehash, taskid):
     return result
 
 
+def process_initializer(cwd):
+    """Initializes the environment of the child process"""
+    os.chdir(cwd)
+    os.environ["NO_ET"] = "1"
+
+
 class MultiProcPlugin(DistributedPluginBase):
     """
     Execute workflow with multiprocessing, not sending more jobs at once
@@ -137,13 +143,15 @@ def __init__(self, plugin_args=None):
             mp_context = mp.context.get_context(self.plugin_args.get("mp_context"))
             self.pool = ProcessPoolExecutor(
                 max_workers=self.processors,
-                initializer=os.chdir,
+                initializer=process_initializer,
                 initargs=(self._cwd,),
                 mp_context=mp_context,
             )
         except (AttributeError, TypeError):
             # Python < 3.7 does not support initialization or contexts
             self.pool = ProcessPoolExecutor(max_workers=self.processors)
+            result_future = self.pool.submit(process_initializer, self._cwd)
+            wait(result_future, timeout=5)
 
         self._stats = None
 

nipype/pipeline/plugins/tools.py

@@ -125,6 +125,9 @@ def create_pyscript(node, updatehash=False, store_exception=True):
     can_import_matplotlib = False
     pass
 
+import os
+os.environ['NO_ET'] = "1"
+
 from nipype import config, logging
 from nipype.utils.filemanip import loadpkl, savepkl
 from socket import gethostname