Skip to content

Commit

Permalink
[HWKMETRICS-613] Use onErrorResumeNext to ignore deletion errors. If …
Browse files Browse the repository at this point in the history
…a delete operation fails, it will be tried again when the expiration index is reprocessed again.
  • Loading branch information
Stefan Negrea committed Mar 31, 2017
1 parent 6f34f0f commit 58d897c
Showing 1 changed file with 2 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -112,8 +112,9 @@ public Completable call(JobDetails jobDetails) {

return expirationIndexResults
.concatMap(metricId -> metricsService.deleteMetric(metricId))
.doOnError(e -> {
.onErrorResumeNext(e -> {
logger.error("Failed to delete metric data", e);
return Observable.empty();
})
.toCompletable();
}
Expand Down

0 comments on commit 58d897c

Please sign in to comment.