From 71b4d50f6e6195be9999e8bc53118adb55e921f1 Mon Sep 17 00:00:00 2001 From: Martin Chacon Piza Date: Wed, 1 Aug 2018 13:03:51 +0200 Subject: [PATCH] Fixed the handling of metrics outside of the retention policy Change-Id: I909c10eede6a0835ea02ca334914396dd1119801 Story: 2003202 Task: 23358 --- monasca_persister/repositories/persister.py | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/monasca_persister/repositories/persister.py b/monasca_persister/repositories/persister.py index 48095402..ba8e83ed 100644 --- a/monasca_persister/repositories/persister.py +++ b/monasca_persister/repositories/persister.py @@ -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))