Skip to content

Commit 81ce973

Browse files
honzakraldi
authored andcommitted
Make sure data always goes to new index
Fixes pypi#3746
1 parent 359b75e commit 81ce973

File tree

1 file changed

+6
-2
lines changed

1 file changed

+6
-2
lines changed

warehouse/search/tasks.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,10 @@ def _project_docs(db):
9494
for release in windowed_query(release_data, Release.name, 50000):
9595
p = ProjectDocType.from_db(release)
9696
p.full_clean()
97-
yield p.to_dict(include_meta=True)
97+
doc = p.to_dict(include_meta=True)
98+
if '_index' in doc:
99+
del doc['_index']
100+
yield doc
98101

99102

100103
@tasks.task(ignore_result=True, acks_late=True)
@@ -143,7 +146,8 @@ def reindex(request):
143146
try:
144147
request.db.execute("SET statement_timeout = '600s'")
145148

146-
for _ in parallel_bulk(client, _project_docs(request.db)):
149+
for _ in parallel_bulk(client, _project_docs(request.db),
150+
index=new_index_name):
147151
pass
148152
except: # noqa
149153
new_index.delete()

0 commit comments

Comments
 (0)