Making the incremental reindexer robust w/ respect to missing destination index.

8-incremental-reindexer.py

@@ -90,7 +90,11 @@ def on_msg_callback(channel, method, properties, body):
     es = Elasticsearch([cfg['reindexer']['destination_url']], timeout=60)
     index = cfg['reindexer']['destination_index']
 
-    es.indices.refresh(index=index)
+    try:
+        es.indices.refresh(index=index)
+    except NotFoundError:
+        # the destination index may not be already present
+        pass
 
     the_query = dict()
     the_query['query'] = dict()