fixes #129

Boerderij · Apr 29, 2019 · 97c6756 · 97c6756
1 parent a64d7f0
commit 97c6756
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/varken/dbmanager.py b/varken/dbmanager.py
@@ -28,8 +28,12 @@ def __init__(self, server):
             self.logger.info("Creating varken database")
             self.influx.create_database('varken')
 
-            self.logger.info("Creating varken retention policy (30d/1h)")
-            self.influx.create_retention_policy('varken 30d/1h', '30d', '1', 'varken', False, '1h')
+        retention_policies = [policy['name'] for policy in self.influx.get_list_retention_policies(database='varken')]
+
+        # Fix name bug by adding retention policy retroactively
+        if 'varken 30d-1h' not in retention_policies:
+            self.logger.info("Creating varken retention policy (30d-1h)")
+            self.influx.create_retention_policy('varken 30d-1h', '30d', '1', 'varken', False, '1h')
 
     def write_points(self, data):
         d = data