v2.1.4 Work with multiple client versions

Author: akariv

tableschema_elasticsearch/VERSION

@@ -1 +1 @@
-2.1.3
+2.1.4

tableschema_elasticsearch/storage.py

@@ -11,7 +11,7 @@
 import uuid
 
 import logging
-from elasticsearch import Elasticsearch
+from elasticsearch import Elasticsearch, __version__ as es_version
 from elasticsearch.helpers import streaming_bulk
 from elasticsearch.exceptions import RequestError
 
@@ -79,7 +79,10 @@ def put_mapping(self, bucket, descriptor, index_name, mapping_generator_cls):
         mapping = mappers.descriptor_to_mapping(
             descriptor, mapping_generator_cls=mapping_generator_cls
         )
-        self.__es.indices.put_mapping(index=index_name, **mapping)
+        if es_version[0] < 8:
+            self.__es.indices.put_mapping(index=index_name, body=mapping)
+        else:
+            self.__es.indices.put_mapping(index=index_name, **mapping)
 
     def generate_doc_id(self, row, primary_key):
         return '/'.join([str(row.get(k)) for k in primary_key])