This commit is contained in:
Nicholas St. Germain 2019-04-29 10:45:56 -05:00
parent 751ed96444
commit 29e4e57e20

View file

@ -33,7 +33,7 @@ class DBManager(object):
# 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(name='varken 30d-1h', duration='30d', replication='1',
self.influx.create_retention_policy(name='varken 30d-1h', duration='30d', replication='1',
database='varken', default=True, shard_duration='1h')
def write_points(self, data):