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

Disabling the verification of the number of records before triggering the reindexation

parent 0e054bfb
Branches
Tags
No related merge requests found
...@@ -114,12 +114,12 @@ def on_msg_callback(channel, method, properties, body): ...@@ -114,12 +114,12 @@ def on_msg_callback(channel, method, properties, body):
# return # return
if count_es != count_ref: # if count_es != count_ref:
logging.warning('Documents are still being pushed to the source index for dataset with uuid = %s' % uuid) # logging.warning('Documents are still being pushed to the source index for dataset with uuid = %s' % uuid)
logging.debug('count_es = %i; count_ref = %i' % (count_es, count_ref)) # logging.debug('count_es = %i; count_ref = %i' % (count_es, count_ref))
time.sleep(5) # time.sleep(5)
channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1) # channel.basic_nack(delivery_tag = method.delivery_tag, requeue=1)
return # return
# 1. remove already existing docs from destination index # 1. remove already existing docs from destination index
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment