Merge "Use TaskRunner.as_task() for the create retry delay"
This commit is contained in:
commit
cdc833d0f5
|
@ -907,9 +907,7 @@ class Resource(object):
|
||||||
delay = timeutils.retry_backoff_delay(count[action],
|
delay = timeutils.retry_backoff_delay(count[action],
|
||||||
jitter_max=2.0)
|
jitter_max=2.0)
|
||||||
waiter = scheduler.TaskRunner(pause)
|
waiter = scheduler.TaskRunner(pause)
|
||||||
waiter.start(timeout=delay)
|
yield waiter.as_task(timeout=delay)
|
||||||
while not waiter.step():
|
|
||||||
yield
|
|
||||||
try:
|
try:
|
||||||
yield self._do_action(action, self.properties.validate)
|
yield self._do_action(action, self.properties.validate)
|
||||||
if action == self.CREATE:
|
if action == self.CREATE:
|
||||||
|
|
Loading…
Reference in New Issue