From e44ddefb434d142b047242a094e5f2f5b071072c Mon Sep 17 00:00:00 2001 From: "Nicholas St. Germain" Date: Mon, 29 Apr 2019 10:25:06 -0500 Subject: [PATCH] fixes #129 --- varken/dbmanager.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/varken/dbmanager.py b/varken/dbmanager.py index c321469..e0b0bd5 100644 --- a/varken/dbmanager.py +++ b/varken/dbmanager.py @@ -28,8 +28,12 @@ class DBManager(object): 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