diff --git a/LTA/LTAIngest/ingestpipeline.py b/LTA/LTAIngest/ingestpipeline.py index 16e1da5471e7fafa788fda14bfe8c7cd211c0fe8..fee189c0d1bfe54f82a8fccaab60d073f87a64e9 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__)