From d6f69ab68d456a5ecd9759ca484638b716eb6ea7 Mon Sep 17 00:00:00 2001
From: Jorrit Schaap <schaap@astron.nl>
Date: Tue, 12 Jan 2016 09:23:22 +0000
Subject: [PATCH] Task #8598: log waiting time when retrying
---
LTA/LTAIngest/ingestpipeline.py | 4 +++-
1 file changed, 3 insertions(+), 1 deletion(-)
diff --git a/LTA/LTAIngest/ingestpipeline.py b/LTA/LTAIngest/ingestpipeline.py
index 16e1da5471e..fee189c0d1b 100755
--- a/LTA/LTAIngest/ingestpipeline.py
+++ b/LTA/LTAIngest/ingestpipeline.py
@@ -522,7 +522,9 @@ class IngestPipeline():
break
retry += 1
if retry < times:
- time.sleep(random.randint(30, 60) * retry)
+ wait_time = random.randint(30, 60) * retry
+ self.logger.debug('waiting %d seconds before trying %s again' % (wait_time, self.JobId))
+ time.sleep(wait_time)
if error:
raise PipelineError(errortext + ' tried %s times but failed on %s. Got the following errors: %s' % (retry, self.JobId, error), func.__name__)
--
GitLab