From 3dde66dd337cd9401bad5576d5f438e3e6e46870 Mon Sep 17 00:00:00 2001
From: ryan-brandt <ryan.brandt@hpe.com>
Date: Tue, 3 Oct 2017 11:14:45 -0600
Subject: [PATCH] Allow persister to handle retention policies in influx

Change-Id: I99f3bc265f347c805fc13cad5e857f70f791851a
---
 monasca_persister/repositories/persister.py | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

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: