Commit 0039dfe8 authored by Damien DESPRES's avatar Damien DESPRES
Browse files

migration es7

parent b7a04ab9
Pipeline #18697 passed with stages
in 19 seconds
......@@ -79,7 +79,7 @@ def on_msg_callback(channel, method, properties, body):
the_query['query']['term'] = {'uuid.keyword': '{0}'.format(uuid)}
es_source.indices.refresh(index=cfg['reindexer']['source_index'])
count_es = es_source.count(cfg['reindexer']['source_index'], body=the_query).get('count')
count_es = es_source.count(index=cfg['reindexer']['source_index'], doc_type='_doc', body=the_query).get('count')
# logging.debug("%i document(s) found in the source index with uuid = %s" % (count1, uuid))
# if uuid.endswith('.full'):
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment