rebased on main and added new partial parsing event

dbt-labs · Nov 9, 2021 · 31acb95 · 31acb95
1 parent 683190b
commit 31acb95
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 2 deletions.
diff --git a/core/dbt/events/types.py b/core/dbt/events/types.py
@@ -857,6 +857,14 @@ def message(self) -> str:
         return "Unable to do partial parsing because env vars used in profiles.yml have changed"
 
 
+@dataclass
+class PartialParsingDeletedMetric(DebugLevel, Cli, File):
+    id: str
+
+    def message(self) -> str:
+        return f"Partial parsing: deleted metric {self.id}"
+
+
 @dataclass
 class ManifestWrongMetadataVersion(DebugLevel, Cli, File):
     version: str
@@ -2253,6 +2261,7 @@ def dump_callable():
     PartialParsingFailedBecauseProfileChange()
     PartialParsingFailedBecauseNewProjectDependency()
     PartialParsingFailedBecauseHashChanged()
+    PartialParsingDeletedMetric('')
     ParsedFileLoadFailed(path='', exc=Exception(''))
     PartialParseSaveFileNotFound()
     StaticParserCausedJinjaRendering(path='')

diff --git a/core/dbt/parser/partial.py b/core/dbt/parser/partial.py
@@ -10,7 +10,7 @@
     PartialParsingEnabled, PartialParsingAddedFile, PartialParsingDeletedFile,
     PartialParsingUpdatedFile, PartialParsingNodeMissingInSourceFile, PartialParsingMissingNodes,
     PartialParsingChildMapMissingUniqueID, PartialParsingUpdateSchemaFile,
-    PartialParsingDeletedSource, PartialParsingDeletedExposure
+    PartialParsingDeletedSource, PartialParsingDeletedExposure, PartialParsingDeletedMetric
 )
 from dbt.node_types import NodeType
 
@@ -870,7 +870,7 @@ def delete_schema_metric(self, schema_file, metric_dict):
                     self.deleted_manifest.metrics[unique_id] = \
                         self.saved_manifest.metrics.pop(unique_id)
                     schema_file.metrics.remove(unique_id)
-                    logger.debug(f"Partial parsing: deleted metric {unique_id}")
+                    fire_event(PartialParsingDeletedMetric(id=unique_id))
 
     def get_schema_element(self, elem_list, elem_name):
         for element in elem_list: