From 639e8cd4a4da69518f6a0d46b7849adc00e2c51a Mon Sep 17 00:00:00 2001 From: Etienne Pelletier Date: Thu, 22 Jun 2023 15:45:03 +0000 Subject: [PATCH] further remove use of postional arguments with elasticsearch --- msc_pygeoapi/connector/elasticsearch_.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/msc_pygeoapi/connector/elasticsearch_.py b/msc_pygeoapi/connector/elasticsearch_.py index 09684d5a..d23a64c4 100644 --- a/msc_pygeoapi/connector/elasticsearch_.py +++ b/msc_pygeoapi/connector/elasticsearch_.py @@ -117,8 +117,8 @@ def create(self, index_name, mapping, overwrite=False): LOGGER.info('{} index already exists.') return False - elif self.Elasticsearch.indices.exists(index_name) and overwrite: - self.Elasticsearch.indices.delete(index_name) + elif self.Elasticsearch.indices.exists(index=index_name) and overwrite: + self.Elasticsearch.indices.delete(index=index_name) LOGGER.info(f'Deleted existing {index_name} index.') self.Elasticsearch.indices.create( @@ -172,7 +172,7 @@ def delete(self, indexes): raise ValueError(msg) LOGGER.info(f'Deleting indexes {indexes}') - self.Elasticsearch.indices.delete(indexes) + self.Elasticsearch.indices.delete(index=indexes) return True @@ -217,7 +217,7 @@ def create_alias(self, alias, index, overwrite=False): :return: `bool` of index alias creation status """ - if not self.Elasticsearch.indices.exists_alias(alias): + if not self.Elasticsearch.indices.exists_alias(name=alias): self.Elasticsearch.indices.put_alias(index=index, name=alias) elif overwrite: self.Elasticsearch.indices.update_aliases(