Merge "Use correct time.sleep argument."
This commit is contained in:
commit
f184a7cfbd
@ -260,10 +260,9 @@ class Stream(object):
|
|||||||
# function that does this.
|
# function that does this.
|
||||||
self.log.exception(
|
self.log.exception(
|
||||||
"Elastic Search not responding on attempt %d" % i)
|
"Elastic Search not responding on attempt %d" % i)
|
||||||
time.sleep(NUMBER_OF_RETRIES)
|
time.sleep(SLEEP_TIME)
|
||||||
continue
|
continue
|
||||||
|
else:
|
||||||
if i == NUMBER_OF_RETRIES - 1:
|
|
||||||
elapsed = format_timedelta(datetime.datetime.now() - started_at)
|
elapsed = format_timedelta(datetime.datetime.now() - started_at)
|
||||||
msg = ("Console logs not available after %ss for %s %d,%d,%s" %
|
msg = ("Console logs not available after %ss for %s %d,%d,%s" %
|
||||||
(elapsed, job.name, event.change, event.rev,
|
(elapsed, job.name, event.change, event.rev,
|
||||||
|
Loading…
Reference in New Issue
Block a user