Fix index creation

2026-08-29 02:07:35 +00:00 · 2019-04-23 12:38:25 -04:00
parent a2998f3968
commit 7f85b1b346
1 changed files with 4 additions and 3 deletions
@@ -209,9 +209,10 @@ def create_indexes(names, settings=None):
            if not index.exists():
                logger.debug("Creating Elasticsearch index: {0}".format(name))
                if settings is None:
-                    settings = dict(number_of_shards=1,
-                                    number_of_replicas=1)
-                index.put_settings(body=settings, preserve_existing=True)
+                    index.settings(number_of_shards=1,
+                                   number_of_replicas=1)
+                else:
+                    index.settings(**settings)
                index.create()
        except Exception as e:
            raise ElasticsearchError(