Loading src/tests/mwc26-f5ga/AI_analytics_engine/clients/influxdb_fetcher.py +5 −0 Original line number Diff line number Diff line Loading @@ -119,6 +119,11 @@ class InfluxDBFetcher: LOGGER.debug(f"Processing {len(table)} rows from InfluxDB response") # Sort by time column (old to new) if it exists if 'time' in table.columns: table = table.sort_values(by='time', ascending=True) LOGGER.debug("Sorted data by time (ascending: old to new)") # Define columns for each output dataframe full_columns = ['bandwidth_utilization', 'latency', 'time', 'link_id'] metric_columns = ['bandwidth_utilization', 'latency'] Loading Loading
src/tests/mwc26-f5ga/AI_analytics_engine/clients/influxdb_fetcher.py +5 −0 Original line number Diff line number Diff line Loading @@ -119,6 +119,11 @@ class InfluxDBFetcher: LOGGER.debug(f"Processing {len(table)} rows from InfluxDB response") # Sort by time column (old to new) if it exists if 'time' in table.columns: table = table.sort_values(by='time', ascending=True) LOGGER.debug("Sorted data by time (ascending: old to new)") # Define columns for each output dataframe full_columns = ['bandwidth_utilization', 'latency', 'time', 'link_id'] metric_columns = ['bandwidth_utilization', 'latency'] Loading