Make rollover init step idempotent (#1964)

* Make rollover init step idempotent Signed-off-by: Pavol Loffay <[email protected]> * Fix index already exists Signed-off-by: Pavol Loffay <[email protected]> * Use index exists paramater Signed-off-by: Pavol Loffay <[email protected]>
jaegertracing · Dec 5, 2019 · c1bc28d · c1bc28d
1 parent 9e68cc1
commit c1bc28d
Showing 1 changed file with 2 additions and 6 deletions.
diff --git a/plugin/storage/es/esRollover.py b/plugin/storage/es/esRollover.py
@@ -108,12 +108,8 @@ def create_index(client, name):
     Create archive index
     """
     print('Creating index {}'.format(name))
-    create = curator.CreateIndex(client=client, name=name)
-    try:
-        create.do_action()
-    except curator.exceptions.FailedExecution as e:
-        if "index_already_exists_exception" not in str(e) and "resource_already_exists_exception" not in str(e):
-            raise e
+    create = curator.CreateIndex(client=client, name=name, ignore_existing=True)
+    create.do_action()
 
 
 def create_aliases(client, alias_name, archive_index_name):