From d6dd60c6fdb708000842f94a4980f29b69fa776e Mon Sep 17 00:00:00 2001 From: sulantha Date: Thu, 7 Jan 2021 14:45:01 -0800 Subject: [PATCH] Issue #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. --- nipype/pipeline/engine/nodes.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/nipype/pipeline/engine/nodes.py b/nipype/pipeline/engine/nodes.py index 2fbac875ab..32322b5f69 100644 --- a/nipype/pipeline/engine/nodes.py +++ b/nipype/pipeline/engine/nodes.py @@ -610,9 +610,9 @@ def _get_inputs(self): # 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"] + input_tries = int(self.config["execution"]["input_tries"]) + input_retry_delay = int(self.config["execution"]["input_retry_delay"]) + input_retry_exp_backoff_factor = int(self.config["execution"]["input_retry_exp_backoff_factor"]) for try_n in range(input_tries): try: self.set_input(key, deepcopy(output_value))