Allows in the bulk method to indicate the index only in the signature

vrcmarcos · Mar 2, 2021 · c8aa31d · c8aa31d
1 parent 3a5f7c5
commit c8aa31d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/elasticmock/fake_elasticsearch.py b/elasticmock/fake_elasticsearch.py
@@ -352,7 +352,7 @@ def bulk(self, body, index=None, doc_type=None, params=None, headers=None):
                     action = next(iter(line.keys()))
 
                     version = 1
-                    index = line[action]['_index']
+                    index = line[action].get('_index') or index
                     doc_type = line[action].get('_type', "_doc")  # _type is deprecated in 7.x
 
                     if action in ['delete', 'update'] and not line[action].get("_id"):