diff --git a/influxdb.py b/influxdb.py index 370fb90..4fb047a 100644 --- a/influxdb.py +++ b/influxdb.py @@ -219,7 +219,7 @@ class InfluxDataGetter: data_frame.loc[index, variable] = NaN variables_info[variable]["expired_ranges"].append([row["timestamp"]]) elif row["expired"] == "False": - if len(variables_info[variable]["expired_ranges"]) > 0: + if len(variables_info[variable]["expired_ranges"]) > 0 and len(variables_info[variable]["expired_ranges"][-1]) == 1: variables_info[variable]["expired_ranges"][-1].append(row["timestamp"]) data_frame.reset_index() data_frame.drop(["expired"], axis=1, inplace=True)