Refresh and proceed on conflicts upon delete_by_query

workers/reindexer.py

@@ -136,10 +136,10 @@ def on_msg_callback(channel, method, properties, body):
     the_query['query']['term'] = {'uuid.keyword': '{0}'.format(uuid)}
 
     try:
-        res = es.delete_by_query(index, doc_type='_doc', body=the_query)
-        logging.debug(res)
-        res = es.indices.refresh(index=index)
+        res = es.delete_by_query(index, doc_type='_doc', body=the_query, conflicts='proceed', refresh=True)
         logging.debug(res)
+        #res = es.indices.refresh(index=index)
+        #logging.debug(res)
     except NotFoundError:
         pass
     except Exception as e: