Increase wait sleeps in node flush/unflush
This commit is contained in:
parent
14e9ba892c
commit
b9774bdf03
|
@ -146,9 +146,9 @@ def flush_node(zk_conn, node, wait):
|
||||||
click.echo(retmsg)
|
click.echo(retmsg)
|
||||||
retmsg = ""
|
retmsg = ""
|
||||||
if lock_wait:
|
if lock_wait:
|
||||||
time.sleep(1)
|
time.sleep(2)
|
||||||
while zkhandler.readdata(zk_conn, '/locks/flush_lock') == 'True':
|
while zkhandler.readdata(zk_conn, '/locks/flush_lock') == 'True':
|
||||||
time.sleep(1)
|
time.sleep(2)
|
||||||
click.echo('Previous flush completed. Proceeding with flush.')
|
click.echo('Previous flush completed. Proceeding with flush.')
|
||||||
|
|
||||||
# Add the new domain to Zookeeper
|
# Add the new domain to Zookeeper
|
||||||
|
@ -158,9 +158,9 @@ def flush_node(zk_conn, node, wait):
|
||||||
|
|
||||||
# Wait cannot be triggered from the API
|
# Wait cannot be triggered from the API
|
||||||
if wait:
|
if wait:
|
||||||
time.sleep(1)
|
time.sleep(2)
|
||||||
while zkhandler.readdata(zk_conn, '/locks/flush_lock') == 'True':
|
while zkhandler.readdata(zk_conn, '/locks/flush_lock') == 'True':
|
||||||
time.sleep(1)
|
time.sleep(2)
|
||||||
|
|
||||||
return True, retmsg
|
return True, retmsg
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue