Update es.py

1 year ago · 2ffadcb9bc
1 changed files with 1 additions and 4 deletions
--- a/apps/common/plugins/es.py
+++ b/apps/common/plugins/es.py
@ -131,10 +131,7 @@ class ES(object):
                }

            try:
-                if version == '6':
-                    self.es.indices.create(self.index, body=mappings)
-                else:
-                    self.es.indices.create(index=self.index, body=mappings)
+                self.es.indices.create(index=self.index, body=mappings)
            except RequestError as e:
                if e.error == 'resource_already_exists_exception':
                    logger.warning(e)