From aa281afd7a66b46e475185eeb4708311a403be42 Mon Sep 17 00:00:00 2001
From: Brice Copy <Brice.Copy@cern.ch>
Date: Mon, 31 Aug 2020 15:03:19 +0200
Subject: [PATCH] Add warn logging for Influxdb
---
dashetl/etl.py | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/dashetl/etl.py b/dashetl/etl.py
index 29c643d..1e022e0 100644
--- a/dashetl/etl.py
+++ b/dashetl/etl.py
@@ -75,7 +75,7 @@ def filter(measurement, spark_dataframe ,filter_lambda=None):
def extraction(measurements, start_date, end_date, filter_lambda=None, tag_lookup_lambda = None, measurement_lookup_lambda = ( lambda x: x )):
winccoaDataset = build_dataset(measurements, start_date, end_date)
- logging.debug("Connecting to INFLUXDB {}@{}:{} DB : {}".format(os.environ.get("INFLUXDB_USERNAME"),os.environ.get("INFLUXDB_HOST"), os.environ.get("INFLUXDB_PORT"), os.environ.get("INFLUXDB_DATABASE")))
+ logging.warn("Connecting to INFLUXDB {}@{}:{} DB : {}".format(os.environ.get("INFLUXDB_USERNAME"),os.environ.get("INFLUXDB_HOST"), os.environ.get("INFLUXDB_PORT"), os.environ.get("INFLUXDB_DATABASE")))
client = DataFrameClient(host=os.environ.get("INFLUXDB_HOST"), port=int(os.environ.get("INFLUXDB_PORT")),
username=os.environ.get("INFLUXDB_USERNAME"),
password=os.environ.get("INFLUXDB_PASSWORD"),
--
GitLab