Issue #3288. Added logger entry when retry is triggered

nipy · Jan 8, 2021 · 87ab436 · 87ab436
1 parent d6dd60c
commit 87ab436
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/nipype/pipeline/engine/nodes.py b/nipype/pipeline/engine/nodes.py
@@ -620,7 +620,11 @@ def _get_inputs(self):
                     except traits.TraitError as e:
                         traits_err = e
                     if input_tries != 1:
-                        time.sleep(input_retry_delay*try_n*input_retry_exp_backoff_factor)
+                        sleep_time = input_retry_delay*try_n*input_retry_exp_backoff_factor
+                        logger.warning("Input set failed for : {0} -> {1}. Retrying in {2} secs. ".format(key,
+                                                                                                          results_fname,
+                                                                                                          sleep_time))
+                        time.sleep(sleep_time)
                 if traits_err is not None:
                     msg = (
                         traits_err.args[0],