openstack/monasca-persister
Code Issues Proposed changes

Merge "Allow persister to handle retention policies in influx"

Browse Source
This commit is contained in:
Zuul 2018-01-09 23:53:04 +00:00 committed by Gerrit Code Review
commit c923911cb5
1 changed files with 7 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
monasca_persister/repositories/persister.py
View File

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