Skip to content
Snippets Groups Projects
Commit e82c3b08 authored by Alessandro Cerioni's avatar Alessandro Cerioni
Browse files

Waiting progressively longer for delete_by_query to be done - II

parent cbb5016b
Branches
Tags
No related merge requests found
...@@ -140,13 +140,15 @@ def on_msg_callback(channel, method, properties, body): ...@@ -140,13 +140,15 @@ def on_msg_callback(channel, method, properties, body):
logging.debug(res) logging.debug(res)
task_id = res['task'] task_id = res['task']
# wait until ES is done # wait until ES is done
seconds_to_sleep_for = 1
while True: while True:
res = es.tasks.get(task_id=task_id) res = es.tasks.get(task_id=task_id)
logging.debug(res) logging.debug(res)
completed = res['completed'] completed = res['completed']
if not completed: if not completed:
logging.info('Waiting for delete_by_query to complete...') logging.info('Waiting for delete_by_query to complete: sleeping for %i seconds...' % seconds_to_sleep_for)
time.sleep(5) time.sleep(seconds_to_sleep_for)
seconds_to_sleep_for += 1
else: else:
break break
except NotFoundError: except NotFoundError:
......
...@@ -177,13 +177,15 @@ def callback(channel, method, properties, body): ...@@ -177,13 +177,15 @@ def callback(channel, method, properties, body):
logging.debug(res) logging.debug(res)
task_id = res['task'] task_id = res['task']
# wait until ES is done # wait until ES is done
seconds_to_sleep_for = 1
while True: while True:
res = destin_es.tasks.get(task_id=task_id) res = es.tasks.get(task_id=task_id)
logging.debug(res) logging.debug(res)
completed = res['completed'] completed = res['completed']
if not completed: if not completed:
logging.info('Waiting for delete_by_query to complete...') logging.info('Waiting for delete_by_query to complete: sleeping for %i seconds...' % seconds_to_sleep_for)
time.sleep(5) time.sleep(seconds_to_sleep_for)
seconds_to_sleep_for += 1
else: else:
break break
except Exception as e: except Exception as e:
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment