|
@@ -82,8 +82,15 @@ class InfluxdbHandler:
|
|
try:
|
|
try:
|
|
# result of the query is a defaultdict
|
|
# result of the query is a defaultdict
|
|
result = self.client.query(query)
|
|
result = self.client.query(query)
|
|
|
|
+
|
|
|
|
+ if len(list(result.values())) > 0:
|
|
|
|
|
|
- return list(result.values())[0]
|
|
|
|
|
|
+ return list(result.values())[0]
|
|
|
|
+
|
|
|
|
+ else:
|
|
|
|
+
|
|
|
|
+ return pd.DataFrame()
|
|
|
|
+
|
|
except Exception as e:
|
|
except Exception as e:
|
|
self._logger.log_and_raise_error(
|
|
self._logger.log_and_raise_error(
|
|
("Could not query to dataframe. "
|
|
("Could not query to dataframe. "
|