diff --git a/dashetl/etl.py b/dashetl/etl.py index 29c643df17a8362e1d3f9c5d3a60a2b95a75923f..1e022e09b4af74da20588051be61aa4ada62f023 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"),