Fix kinesis_stream wait loop pause. (#64283)
This commit is contained in:
parent
fbdd295cef
commit
d6a51807cd
1 changed files with 3 additions and 3 deletions
|
@ -436,16 +436,16 @@ def wait_for_status(client, stream_name, status, wait_timeout=300,
|
||||||
status_achieved = True
|
status_achieved = True
|
||||||
break
|
break
|
||||||
|
|
||||||
elif status == 'DELETING' and not check_mode:
|
else:
|
||||||
if not find_success:
|
if not find_success:
|
||||||
status_achieved = True
|
status_achieved = True
|
||||||
break
|
break
|
||||||
|
|
||||||
else:
|
|
||||||
time.sleep(polling_increment_secs)
|
|
||||||
except botocore.exceptions.ClientError as e:
|
except botocore.exceptions.ClientError as e:
|
||||||
err_msg = to_native(e)
|
err_msg = to_native(e)
|
||||||
|
|
||||||
|
time.sleep(polling_increment_secs)
|
||||||
|
|
||||||
if not status_achieved:
|
if not status_achieved:
|
||||||
err_msg = "Wait time out reached, while waiting for results"
|
err_msg = "Wait time out reached, while waiting for results"
|
||||||
else:
|
else:
|
||||||
|
|
Loading…
Reference in a new issue