Merge "Fixed the handling of metrics outside of the retention policy"

This commit is contained in:
Zuul 2018-08-06 13:53:57 +00:00 committed by Gerrit Code Review
commit 4bbb7d1f03
1 changed files with 4 additions and 2 deletions

View File

@ -57,8 +57,10 @@ class Persister(object):
self._data_points = []
self._consumer.commit()
except Exception as ex:
if ex.message.startswith("400: partial write: points beyond retention policy dropped"):
LOG.info("Some points older than retention policy were dropped")
if "partial write: points beyond retention policy dropped" in ex.message:
LOG.warning("Some points older than retention policy were dropped")
self._data_points = []
self._consumer.commit()
else:
LOG.exception("Error writing to database: {}"
.format(self._data_points))