diff --git a/elasticsearch/helpers/__init__.py b/elasticsearch/helpers/__init__.py index 01d0b6cf..8eb2e761 100644 --- a/elasticsearch/helpers/__init__.py +++ b/elasticsearch/helpers/__init__.py @@ -131,7 +131,7 @@ def _process_bulk_chunk(client, bulk_actions, raise_on_exception=True, raise_on_ if errors: raise BulkIndexError('%i document(s) failed to index.' % len(errors), errors) -def streaming_bulk(client, actions, chunk_size=500, max_chunk_bytes=100 * 1014 * 1024, +def streaming_bulk(client, actions, chunk_size=500, max_chunk_bytes=100 * 1024 * 1024, raise_on_error=True, expand_action_callback=expand_action, raise_on_exception=True, **kwargs): """