fix: revise configuration of resource monitor at the interface level

Author: oesteban

nipype/interfaces/base/core.py

@@ -173,7 +173,7 @@ class BaseInterface(Interface):
     _additional_metadata = []
     _redirect_x = False
     _references = []
-    resource_monitor = True  # Enabled for this interface IFF enabled in the config
+    resource_monitor = None  # Enabled for this interface IFF enabled in the config
     _etelemetry_version_data = None
 
     def __init__(
@@ -202,9 +202,10 @@ def __init__(
         self.inputs.trait_set(**inputs)
 
         self.ignore_exception = ignore_exception
-
-        if resource_monitor is not None:
-            self.resource_monitor = resource_monitor
+        self.resource_monitor = (
+            resource_monitor if resource_monitor is not None
+            else config.resource_monitor
+        )
 
         if from_file is not None:
             self.load_inputs_from_json(from_file, overwrite=True)
@@ -376,18 +377,13 @@ def run(self, cwd=None, ignore_exception=None, **inputs):
             if successful, results
 
         """
-        rtc = RuntimeContext(
-            resource_monitor=config.resource_monitor and self.resource_monitor,
-            ignore_exception=ignore_exception
-            if ignore_exception is not None
-            else self.ignore_exception,
-        )
 
         with indirectory(cwd or os.getcwd()):
             self.inputs.trait_set(**inputs)
         self._check_mandatory_inputs()
         self._check_version_requirements(self.inputs)
 
+        rtc = RuntimeContext()
         with rtc(self, cwd=cwd, redirect_x=self._redirect_x) as runtime:
 
             # Grab inputs now, as they should not change during execution

nipype/interfaces/base/support.py

@@ -31,20 +31,21 @@ class RuntimeContext(AbstractContextManager):
 
     __slots__ = ("_runtime", "_resmon", "_ignore_exc")
 
-    def __init__(self, resource_monitor=False, ignore_exception=False):
+    def __init__(self):
         """Initialize the context manager object."""
-        self._ignore_exc = ignore_exception
-        self._resmon = resource_monitor
+        self._ignore_exc = False
+        self._resmon = None
 
 
-    def __call__(self, interface, cwd=None, redirect_x=False):
+    def __call__(self, interface, cwd=None, redirect_x=False, ignore_exception=False):
         """Generate a new runtime object."""
         # Tear-up: get current and prev directories
         _syscwd = rgetcwd(error=False)  # Recover when wd does not exist
         if cwd is None:
             cwd = _syscwd
 
-        if self._resmon:
+        self._ignore_exc = ignore_exception or interface.ignore_exception
+        if interface.resource_monitor is True:
             _proc_pid = os.getpid()
             self._resmon = ResourceMonitor(
                 _proc_pid,