Skip to content

Commit 53fa6be

Browse files
committed
Fix delete_influx function
1 parent 6173d78 commit 53fa6be

File tree

1 file changed

+7
-10
lines changed

1 file changed

+7
-10
lines changed

dashboard-writer/utils.py

+7-10
Original file line numberDiff line numberDiff line change
@@ -43,16 +43,13 @@ def delete_influx(name):
4343

4444
client = InfluxDBClient(url=inputs.influx_url, token=inputs.token, org=inputs.org_id, debug=False)
4545

46-
if client.health().status == "pass":
47-
start = "1970-01-01T00:00:00Z"
48-
stop = "2099-01-01T00:00:00Z"
49-
50-
delete_api = client.delete_api()
51-
delete_api.delete(
52-
start, stop, f'_measurement="{name}"', bucket=inputs.influx_bucket, org=inputs.org_id,
53-
)
54-
else:
55-
print("\nWARNING: Unable to connect to InfluxDB - please check your credentials\n\n")
46+
start = "1970-01-01T00:00:00Z"
47+
stop = "2099-01-01T00:00:00Z"
48+
49+
delete_api = client.delete_api()
50+
delete_api.delete(
51+
start, stop, f'_measurement="{name}"', bucket=inputs.influx_bucket, org=inputs.org_id,
52+
)
5653

5754

5855
def setup_fs_s3():

0 commit comments

Comments
 (0)