diff --git a/monasca_persister/repositories/persister.py b/monasca_persister/repositories/persister.py index d1a49751..b9e3c8b2 100644 --- a/monasca_persister/repositories/persister.py +++ b/monasca_persister/repositories/persister.py @@ -55,10 +55,13 @@ class Persister(object): self._data_points = [] self._consumer.commit() - except Exception: - LOG.exception("Error writing to database: {}" - .format(self._data_points)) - raise + 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") + else: + LOG.exception("Error writing to database: {}" + .format(self._data_points)) + raise ex def run(self): try: