diff --git a/workers/reindexer.py b/workers/reindexer.py
index 0bc029909e2358cd696039ca0e43b6cc0da28aef..eb7aec5f899fb8495ff524b69c0533fd90ef19ec 100644
--- a/workers/reindexer.py
+++ b/workers/reindexer.py
@@ -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'):