diff --git a/LTA/LTAIngest/ingestpipeline.py b/LTA/LTAIngest/ingestpipeline.py index af6a44ab461ca689fbb46a3c2d03b8dabc370224..f26ba5b52d52a9b1713fdf93583f08cb1945cdbe 100755 --- a/LTA/LTAIngest/ingestpipeline.py +++ b/LTA/LTAIngest/ingestpipeline.py @@ -533,7 +533,7 @@ class IngestPipeline(): break retry += 1 if retry < times: - wait_time = 1 #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: