Merge pull request #6 from jthi3rry/percolators

Reindex percolators after migrating data
jthi3rry · Jan 21, 2016 · ee9da33 · ee9da33
2 parents 0694e55 + 60a1cff
commit ee9da33
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 3 deletions.
diff --git a/README.rst b/README.rst
@@ -150,6 +150,10 @@ All contributions and comments are welcome. Simply create a pull request or repo
 Changelog
 =========
 
+v0.0.5
+------
+* Reindex percolators after migrating data
+
 v0.0.4
 ------
 * Allow passing create and copy kwargs to migrate

diff --git a/slingshot/__init__.py b/slingshot/__init__.py
@@ -1 +1 @@
-__version__ = '0.0.4'
+__version__ = '0.0.5'
diff --git a/slingshot/indices_manager.py b/slingshot/indices_manager.py
@@ -92,14 +92,15 @@ def _process_hits(hits, index):
                     continue
                 yield doc
 
-        # Make sure percolators are copied across too
-        helpers.reindex(self.client, source_index=source_index, target_index=target_index, scan_kwargs={"doc_type": ".percolator"})
         if parallel:
             for _ in helpers.parallel_bulk(self.client, _process_hits(hits, target_index), **bulk_kwargs):
                 pass
         else:
             helpers.bulk(self.client, _process_hits(hits, target_index), stats_only=True, **bulk_kwargs)
 
+        # Make sure percolators are copied across too
+        helpers.reindex(self.client, source_index=source_index, target_index=target_index, scan_kwargs={"doc_type": ".percolator"})
+
     def _generate_name(self, name):
         return ".".join([name, str(int(time.time() * 1000))])