Issue nipy#3288. Implementing input delayed retry for all inputs of the node. Simplified implementation for all inputs (not just File type). Need to be improved for File type later on.

Author: sulantha2006

nipype/pipeline/engine/nodes.py

@@ -14,6 +14,7 @@
 from copy import deepcopy
 from glob import glob
 from logging import INFO
+import time
 
 from tempfile import mkdtemp
 
@@ -605,19 +606,32 @@ def _get_inputs(self):
                         output_value = outputs.dictcopy()[output_name]
                     logger.debug("output: %s", output_name)
 
-                try:
-                    self.set_input(key, deepcopy(output_value))
-                except traits.TraitError as e:
+                traits_err = None
+                # input_tries = 1 # Default no reties
+                # input_retry_delay = 5
+                # input_retry_exponential_backoff_factor = 1
+                input_tries = self.config["execution"]["input_tries"]
+                input_retry_delay = self.config["execution"]["input_retry_delay"]
+                input_retry_exp_backoff_factor = self.config["execution"]["input_retry_exp_backoff_factor"]
+                for try_n in range(input_tries):
+                    try:
+                        self.set_input(key, deepcopy(output_value))
+                        break
+                    except traits.TraitError as e:
+                        traits_err = e
+                    if input_tries != 1:
+                        time.sleep(input_retry_delay*try_n*input_retry_exp_backoff_factor)
+                if traits_err is not None:
                     msg = (
-                        e.args[0],
+                        traits_err.args[0],
                         "",
                         "Error setting node input:",
                         "Node: %s" % self.name,
                         "input: %s" % key,
                         "results_file: %s" % results_fname,
                         "value: %s" % str(output_value),
                     )
-                    e.args = ("\n".join(msg),)
+                    traits_err.args = ("\n".join(msg),)
                     raise
 
         # Successfully set inputs

nipype/utils/config.py

@@ -62,6 +62,9 @@
 poll_sleep_duration = 2
 xvfb_max_wait = 10
 check_version = true
+input_tries = 1
+input_retry_delay = 5
+input_retry_exp_backoff_factor = 1
 
 [monitoring]
 enabled = false