From 868d8060c4b93e9e20e552dfed7a0964a4f9aa1d Mon Sep 17 00:00:00 2001 From: Hariharan Devarajan Date: Wed, 2 Oct 2024 19:11:55 -0700 Subject: [PATCH] fixed indentation --- dfanalyzer/main.py | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/dfanalyzer/main.py b/dfanalyzer/main.py index 18dcc4c..2dc988c 100644 --- a/dfanalyzer/main.py +++ b/dfanalyzer/main.py @@ -505,12 +505,12 @@ def _calculate_time(self): grouped_df = self.events.groupby(["trange", "pid", "tid"]) \ .agg({"compute_time": sum, "io_time": sum, "app_io_time": sum}) \ .groupby(["trange"]).max() - # check if the max io_time > time_granularity - max_io_time = grouped_df.max().compute()['io_time'] - if max_io_time > self.conf.time_granularity: - # throw a warning, running with large granuality - logging.warn(f"The max io_time {max_io_time} exceeds the time_granularity {self.conf.time_granularity}. " \ - f"Please adjust the time_granularity to {int(2 * max_io_time /1e6)}e6 and rerun the analyzer.") + # check if the max io_time > time_granularity + max_io_time = grouped_df.max().compute()['io_time'] + if max_io_time > self.conf.time_granularity: + # throw a warning, running with large granuality + logging.warn(f"The max io_time {max_io_time} exceeds the time_granularity {self.conf.time_granularity}. " \ + f"Please adjust the time_granularity to {int(2 * max_io_time /1e6)}e6 and rerun the analyzer.") grouped_df["io_time"] = grouped_df["io_time"].fillna(0) grouped_df["compute_time"] = grouped_df["compute_time"].fillna(0) grouped_df["app_io_time"] = grouped_df["app_io_time"].fillna(0)