diff --git a/elasticsearch/helpers/__init__.py b/elasticsearch/helpers/__init__.py index 8a349654..df4e1b77 100644 --- a/elasticsearch/helpers/__init__.py +++ b/elasticsearch/helpers/__init__.py @@ -55,7 +55,7 @@ def _chunk_actions(actions, chunk_size, max_chunk_bytes, serializer): bulk_actions, bulk_data = [], [] size, action_count = 0, 0 for action, data in actions: - raw_data, raw_action = action + raw_data, raw_action = data, action action = serializer.dumps(action) cur_size = len(action) + 1