Skip to content

Commit ffc0eac

Browse files
authored
Merge pull request hmalphettes#18 from CoorpAcademy/format-es-errors
Correctly display bulk error from elastic search
2 parents 33986c1 + a4d79ae commit ffc0eac

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

lib/writable-bulk.js

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,10 @@ WritableBulk.prototype._flushBulk = function(callback) {
8282
var bulkItemResp = resp.items[i];
8383
var key = Object.keys(bulkItemResp)[0];
8484
if (bulkItemResp[key].error) {
85-
self.emit('error', new Error(bulkItemResp[key].error));
85+
var err = new Error(bulkItemResp[key].error.reason || bulkItemResp[key].error);
86+
err.reason = bulkItemResp[key].error.reason;
87+
err.type = bulkItemResp[key].error.type;
88+
self.emit('error', err);
8689
}
8790
}
8891
}

0 commit comments

Comments
 (0)