From d932411189b5cc632ec47ae27dc4f0fb92901722 Mon Sep 17 00:00:00 2001 From: Yang Wang Date: Fri, 17 Oct 2025 14:00:48 -0700 Subject: [PATCH 1/4] add config --- .../benchmark_regression_summary_report/lambda_function.py | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/aws/lambda/benchmark_regression_summary_report/lambda_function.py b/aws/lambda/benchmark_regression_summary_report/lambda_function.py index 3c601d9c9d..4bf87a971c 100644 --- a/aws/lambda/benchmark_regression_summary_report/lambda_function.py +++ b/aws/lambda/benchmark_regression_summary_report/lambda_function.py @@ -169,7 +169,7 @@ def get_target(self, config: BenchmarkConfig, end_time: int): target_s = end_time - data_range.comparison_timedelta_s() target_e = end_time self.log_info( - "getting target data for time range " + "getting target data (newest) for time range " f"[{format_ts_with_t(target_s)},{format_ts_with_t(target_e)}] ..." ) target_data = self._fetch_from_benchmark_ts_api( @@ -179,7 +179,7 @@ def get_target(self, config: BenchmarkConfig, end_time: int): source=config.source, ) self.log_info( - f"done. found {len(target_data.time_series)} # of data groups, with time range {target_data.time_range}", + f"done fetching target data (newest). found {len(target_data.time_series)} # of groups, with time range {target_data.time_range}", ) if not target_data.time_range or not target_data.time_range.end: return None, target_s, target_e @@ -236,7 +236,7 @@ def should_use_data( if latest_ts >= cutoff: return True - self.log_info(f"expect latest data to be after {cutoff}, but got {latest_ts}") + self.log_info(f"expect latest data to be after unixtime {cutoff}, but got {latest_ts}") return False def _fetch_from_benchmark_ts_api( From ac0c941b8cfd0d0ea44aedc790746b41515e8a56 Mon Sep 17 00:00:00 2001 From: Yang Wang Date: Fri, 17 Oct 2025 14:03:13 -0700 Subject: [PATCH 2/4] add config --- .../lambda_function.py | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/aws/lambda/benchmark_regression_summary_report/lambda_function.py b/aws/lambda/benchmark_regression_summary_report/lambda_function.py index 4bf87a971c..66e3acaacf 100644 --- a/aws/lambda/benchmark_regression_summary_report/lambda_function.py +++ b/aws/lambda/benchmark_regression_summary_report/lambda_function.py @@ -139,13 +139,13 @@ def process( target, ls, le = self.get_target(config, self.end_time) if not target: self.log_info( - f"no target data found for time range [{ls},{le}] with frequency {report_freq.get_text()}..." + f"skip generate report. no target data found for time range [{ls},{le}] with frequency {report_freq.get_text()}..." ) return baseline, bs, be = self.get_baseline(config, self.end_time) if not baseline: self.log_info( - f"no baseline data found for time range [{bs},{be}] with frequency {report_freq.get_text()}..." + f"skip generate report. no baseline data found for time range[{bs},{be}] with frequency {report_freq.get_text()}..." ) return generator = BenchmarkRegressionReportGenerator( @@ -236,7 +236,9 @@ def should_use_data( if latest_ts >= cutoff: return True - self.log_info(f"expect latest data to be after unixtime {cutoff}, but got {latest_ts}") + self.log_info( + f"expect latest data to be after unixtime {cutoff}, but got {latest_ts}" + ) return False def _fetch_from_benchmark_ts_api( From ff777c7e9fa062ce67a78b2a2753442b17d9cef7 Mon Sep 17 00:00:00 2001 From: Yang Wang Date: Fri, 17 Oct 2025 14:04:27 -0700 Subject: [PATCH 3/4] add config --- .../benchmark_regression_summary_report/lambda_function.py | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/aws/lambda/benchmark_regression_summary_report/lambda_function.py b/aws/lambda/benchmark_regression_summary_report/lambda_function.py index 66e3acaacf..a8458e22a4 100644 --- a/aws/lambda/benchmark_regression_summary_report/lambda_function.py +++ b/aws/lambda/benchmark_regression_summary_report/lambda_function.py @@ -179,7 +179,7 @@ def get_target(self, config: BenchmarkConfig, end_time: int): source=config.source, ) self.log_info( - f"done fetching target data (newest). found {len(target_data.time_series)} # of groups, with time range {target_data.time_range}", + f"Done fetching target data (newest). found {len(target_data.time_series)} # of groups, with time range {target_data.time_range}", ) if not target_data.time_range or not target_data.time_range.end: return None, target_s, target_e @@ -206,7 +206,7 @@ def get_baseline(self, config: BenchmarkConfig, end_time: int): ) self.log_info( - f"Done. found {len(raw_data.time_series)} # of data, with time range {raw_data.time_range}", + f"Done fetching baseline data. found {len(raw_data.time_series)} # of data, with time range {raw_data.time_range}", ) baseline_latest_ts = int(isoparse(raw_data.time_range.end).timestamp()) From 30e75360ced77196374779742240cd751d9a1c92 Mon Sep 17 00:00:00 2001 From: Yang Wang Date: Fri, 17 Oct 2025 14:10:45 -0700 Subject: [PATCH 4/4] add config --- .../lambda_function.py | 18 +++++++++++++----- 1 file changed, 13 insertions(+), 5 deletions(-) diff --git a/aws/lambda/benchmark_regression_summary_report/lambda_function.py b/aws/lambda/benchmark_regression_summary_report/lambda_function.py index a8458e22a4..e1d6a0334d 100644 --- a/aws/lambda/benchmark_regression_summary_report/lambda_function.py +++ b/aws/lambda/benchmark_regression_summary_report/lambda_function.py @@ -139,13 +139,17 @@ def process( target, ls, le = self.get_target(config, self.end_time) if not target: self.log_info( - f"skip generate report. no target data found for time range [{ls},{le}] with frequency {report_freq.get_text()}..." + "skip generate report. no target data found" + f"for time range [{format_ts_with_t(ls)},{format_ts_with_t(le)}]" + f"with frequency {report_freq.get_text()}..." ) return baseline, bs, be = self.get_baseline(config, self.end_time) if not baseline: self.log_info( - f"skip generate report. no baseline data found for time range[{bs},{be}] with frequency {report_freq.get_text()}..." + "skip generate report. no baseline data found for" + f"time range[{format_ts_with_t(bs)},{format_ts_with_t(be)}]" + f"with frequency {report_freq.get_text()}..." ) return generator = BenchmarkRegressionReportGenerator( @@ -179,7 +183,9 @@ def get_target(self, config: BenchmarkConfig, end_time: int): source=config.source, ) self.log_info( - f"Done fetching target data (newest). found {len(target_data.time_series)} # of groups, with time range {target_data.time_range}", + "Done fetching target data (newest)." + f"found {len(target_data.time_series)} # of groups," + f"with time range {target_data.time_range}", ) if not target_data.time_range or not target_data.time_range.end: return None, target_s, target_e @@ -206,7 +212,9 @@ def get_baseline(self, config: BenchmarkConfig, end_time: int): ) self.log_info( - f"Done fetching baseline data. found {len(raw_data.time_series)} # of data, with time range {raw_data.time_range}", + "Done fetching baseline data." + f"found {len(raw_data.time_series)} # of data," + f"with time range {raw_data.time_range}" ) baseline_latest_ts = int(isoparse(raw_data.time_range.end).timestamp()) @@ -237,7 +245,7 @@ def should_use_data( if latest_ts >= cutoff: return True self.log_info( - f"expect latest data to be after unixtime {cutoff}, but got {latest_ts}" + f"expect latest data to be after unixtime {format_ts_with_t(cutoff)}, but got {format_ts_with_t(latest_ts)}" ) return False