Use flush instead of flushed_synced

That removed on opensearch-project/opensearch-py#151
alantang888 · Jan 30, 2024 · 0fa4203 · 0fa4203
1 parent 6672ed5
commit 0fa4203
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 6 deletions.
diff --git a/curator/actions.py b/curator/actions.py
@@ -333,7 +333,7 @@ def do_action(self):
                         )
                 if not self.skip_flush:
                     try:
-                        self.client.indices.flush_synced(index=lst_as_csv, ignore_unavailable=True)
+                        self.client.indices.flush(index=lst_as_csv, ignore_unavailable=True, force=True)
                     except ConflictError as err:
                         if not self.ignore_sync_failures:
                             raise ConflictError(err.status_code, err.error, err.info)

diff --git a/test/unit/testvars.py b/test/unit/testvars.py
@@ -176,11 +176,7 @@
                   }
 verified_nodes  = {'nodes': {'nodeid1': {'name': 'node1'}, 'nodeid2': {'name': 'node2'}}}
 synced_pass     = {
-                    "_shards":{"total":1,"successful":1,"failed":0},
-                    "index_name":{
-                        "total":1,"successful":1,"failed":0,
-                        "failures":[],
-                    }
+                    "_shards":{"total":1,"successful":1,"failed":0}
                   }
 synced_fail     = {
                     "_shards":{"total":1,"successful":0,"failed":1},