When retrying we get deserialized data

This is just a hotfix until a better solution with proper tests come along
2017-07-22 13:13:53 -04:00
parent f1267b52f0
commit ba8772a66f
1 changed files with 1 additions and 1 deletions
@@ -92,7 +92,7 @@ def _process_bulk_chunk(client, bulk_actions, bulk_data, raise_on_exception=True

    try:
        # send the actual request
-        resp = client.bulk('\n'.join(bulk_actions) + '\n', **kwargs)
+        resp = client.bulk('\n'.join(map(client.transport.serializer.dumps, bulk_actions)) + '\n', **kwargs)
    except TransportError as e:
        # default behavior - just propagate exception
        if raise_on_exception: