Elastic: prevent indexing deleted nodes

2018-01-05 15:33:40 +01:00
parent dcd67b6114
commit fdab66a500
1 changed files with 4 additions and 1 deletions
--- a/pillar/cli/elastic.py
+++ b/pillar/cli/elastic.py
@@ -85,7 +85,10 @@ def _public_project_ids() -> typing.List[bson.ObjectId]:
 def _reindex_nodes():
    db = current_app.db()
    nodes_coll = db['nodes']
-    nodes = nodes_coll.find({'project': {'$in': _public_project_ids()}})
+    nodes = nodes_coll.find({
+        'project': {'$in': _public_project_ids()},
+        '_deleted': {'$ne': True},
+    })
    node_count = nodes.count()

    log.info('Nodes %d will be reindexed in Elastic', node_count)