-
Notifications
You must be signed in to change notification settings - Fork 636
fix: Notify items if an error occurs in bulk indexer #615
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
|
Since this is a community submitted pull request, a Jenkins build has not been kicked off automatically. Can an Elastic organization member please verify the contents of this patch and then kick off a build manually? |
|
💚 CLA has been signed |
|
@Anaethelion (as last main contributor) would you mind taking a look at this PR when you get a chance? #179 has been going on for a long time and prevents from using the bulk indexer in many production use-cases where visibility into failed writes is needed. |
* makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err`
✅ Snyk checks have passed. No issues have been found so far.
💻 Catch issues earlier using the plugins for VS Code, JetBrains IDEs, Visual Studio, and Eclipse. |
|
Hi all, I've added some tests to cover the new behaviour, with a slight refactor to make the code more DRY and a minor bug fix. This will be sorted soon, thank you for your patience and for your contribution! |
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
* notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- Co-authored-by: Matt Devy <[email protected]> (cherry picked from commit 6ea4a8a)
fix: Notify items if an error occurs in bulk indexer (#615) * notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- (cherry picked from commit 6ea4a8a) Co-authored-by: ansssu <[email protected]> Co-authored-by: Matt Devy <[email protected]>
fix: Notify items if an error occurs in bulk indexer (#615) * notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- (cherry picked from commit 6ea4a8a) Co-authored-by: ansssu <[email protected]> Co-authored-by: Matt Devy <[email protected]>
fix: Notify items if an error occurs in bulk indexer (#615) * notify items if an error occurs in bulk indexer * fix message error on line 577 * test: OnFailure is called per item * refactor: use a method to handle errors * makes code DRYer * fixes bug where `res.IsError()` resulted in BulkIndexerItem.OnError receiving a nil `err` --------- (cherry picked from commit 6ea4a8a) Co-authored-by: ansssu <[email protected]> Co-authored-by: Matt Devy <[email protected]>
Propagate errors on items. Fix #179