anomaly report generation

Author: ahosler

ads/opctl/operator/lowcode/anomaly/model/base_model.py

@@ -82,9 +82,7 @@ def generate_report(self):
             rc.DataTable(df, label=col, index=True)
             for col, df in self.datasets.full_data_dict.items()
         ]
-        data_table = (
-            rc.Select(blocks=table_blocks) if len(table_blocks) > 1 else table_blocks[0]
-        )
+        data_table = rc.Select(blocks=table_blocks)
         date_column = self.spec.datetime_column.name
 
         blocks = []
@@ -106,9 +104,9 @@ def generate_report(self):
                 plt.xlabel(date_column)
                 plt.ylabel(col)
                 plt.title(f"`{col}` with reference to anomalies")
-                figure_blocks.append(ax)
-            blocks.append(rc.Group(figure_blocks, label=target))
-        plots = rc.Select(blocks=blocks) if len(blocks) > 1 else blocks[0]
+                figure_blocks.append(rc.Widget(ax))
+            blocks.append(rc.Group(*figure_blocks, label=target))
+        plots = rc.Select(blocks)
 
         report_sections = []
         title_text = rc.Heading("Anomaly Detection Report", level=1)
@@ -122,7 +120,7 @@ def generate_report(self):
                     "Based on your dataset, you could have also selected "
                     f"any of the models: `{'`, `'.join(SupportedModels.keys())}`."
                 ),
-                rc.BigNumber(
+                rc.Metric(
                     heading="Analysis was completed in ",
                     value=human_time_friendly(elapsed_time),
                 ),
@@ -259,7 +257,8 @@ def _save_report(
         with tempfile.TemporaryDirectory() as temp_dir:
             report_local_path = os.path.join(temp_dir, "___report.html")
             disable_print()
-            rc.save_report(report_sections, report_local_path)
+            with rc.ReportCreator("My Report") as report:
+                report.save(rc.Block(*report_sections), report_local_path)
             enable_print()
             with open(report_local_path) as f1:
                 with fsspec.open(

ads/opctl/operator/lowcode/forecast/model/base_model.py

@@ -421,10 +421,10 @@ def _save_report(
         if self.spec.generate_report:
             with tempfile.TemporaryDirectory() as temp_dir:
                 report_local_path = os.path.join(temp_dir, "___report.html")
-                # disable_print()
+                disable_print()
                 with rc.ReportCreator("My Report") as report:
                     report.save(rc.Block(*report_sections), report_local_path)
-                # enable_print()
+                enable_print()
 
                 report_path = os.path.join(unique_output_dir, self.spec.report_filename)
                 with open(report_local_path) as f1:

ads/opctl/operator/lowcode/pii/model/report.py

@@ -238,7 +238,7 @@ def build_report(self) -> rc.Group:
     def _make_stats_card(self):
         stats = [
             rc.Heading("Row Summary Statistics", level=2),
-            rc.BigNumber(
+            rc.Metric(
                 heading="Total No. Of Entites Proceed",
                 value=self.spec.total_tokens or 0,
             ),
@@ -297,7 +297,7 @@ def make_view(self):
         title_text = rc.Heading(
             "Personally Identifiable Information Operator Report", level=1
         )
-        time_proceed = rc.BigNumber(
+        time_proceed = rc.Metric(
             heading="Ran at",
             value=self.report_spec.run_summary.timestamp or "today",
         )
@@ -325,11 +325,10 @@ def save_report(self, report_sections=None, report_uri=None, storage_options={})
         with tempfile.TemporaryDirectory() as temp_dir:
             report_local_path = os.path.join(temp_dir, "___report.html")
             disable_print()
-            rc.save_report(
-                report_sections or self.report_sections,
-                path=report_local_path,
-                open=False,
-            )
+            with rc.ReportCreator("My Report") as report:
+                report.save(
+                    rc.Block(report_sections or self.report_sections), report_local_path
+                )
             enable_print()
 
             report_uri = report_uri or self.report_uri
@@ -393,19 +392,19 @@ def _make_summary_stats_card(self) -> rc.Group:
         summary_stats = [
             rc.Heading("Summary Statistics", level=2),
             rc.Group(
-                rc.BigNumber(
+                rc.Metric(
                     heading="Total No. Of Rows",
                     value=self.report_spec.run_summary.total_rows or "unknown",
                 ),
-                rc.BigNumber(
+                rc.Metric(
                     heading="Total No. Of Entites Proceed",
                     value=self.report_spec.run_summary.total_tokens,
                 ),
-                rc.BigNumber(
+                rc.Metric(
                     heading="Rows per second processed",
                     value=process_rate,
                 ),
-                rc.BigNumber(
+                rc.Metric(
                     heading="Total Time Spent",
                     value=human_time_friendly(
                         self.report_spec.run_summary.elapsed_time