Create LogNodeResult event (#11195)

* Create LogNodeResult event

* add msg directly during object creation

.changes/unreleased/Under the Hood-20250107-205838.yaml

@@ -0,0 +1,6 @@
+kind: Under the Hood
+body: Create LogNodeResult event
+time: 2025-01-07T20:58:38.821036Z
+custom:
+    Author: aranke
+    Issue: ' '

core/dbt/events/core_types.proto

@@ -1355,8 +1355,23 @@ message LogTestResultMsg {
     LogTestResult data = 2;
 }
 
+// Q008
+message LogNodeResult {
+    NodeInfo node_info = 1;
+    string description = 2;
+    string status = 3;
+    int32 index = 4;
+    int32 total = 5;
+    float execution_time = 6;
+    string msg = 7;
+}
+
+message LogNodeResultMsg {
+    CoreEventInfo info = 1;
+    LogNodeResult data = 2;
+}
 
-// Skipped Q008, Q009, Q010
+// Skipped Q009, Q010
 
 
 // Q011

core/dbt/events/types.py

@@ -1342,7 +1342,15 @@ def status_to_level(cls, status):
             return EventLevel.INFO
 
 
-# Skipped Q008, Q009, Q010
+class LogNodeResult(DynamicLevel):
+    def code(self) -> str:
+        return "Q008"
+
+    def message(self) -> str:
+        return self.msg
+
+
+# Skipped Q009, Q010
 
 
 class LogStartLine(InfoLevel):

tests/unit/events/test_types.py

@@ -3,6 +3,7 @@
 from dbt.adapters.events.types import PluginLoadError, RollbackFailed
 from dbt.events import core_types_pb2
 from dbt.events.types import (
+    LogNodeResult,
     LogStartLine,
     LogTestResult,
     MainEncounteredError,
@@ -185,3 +186,17 @@ def test_dynamic_level_events():
     msg = msg_from_base_event(event, level=EventLevel.INFO)
     assert msg
     assert msg.info.level == "info"
+
+
+def test_log_node_result():
+    event = LogNodeResult(
+        node_info={},
+        status="error",
+        index=1,
+        total=0,
+        msg="some message",
+    )
+    msg = msg_from_base_event(event, level=EventLevel.ERROR)
+    assert msg
+    assert msg.info.msg == "some message"
+    assert msg.info.level == "error"

tests/unit/test_events.py

@@ -338,6 +338,14 @@ def test_event_codes(self):
         execution_time=0,
         num_failures=0,
     ),
+    core_types.LogNodeResult(
+        description="",
+        status="",
+        index=0,
+        total=0,
+        execution_time=0,
+        msg="",
+    ),
     core_types.LogStartLine(description="", index=0, total=0),
     core_types.LogModelResult(
         description="",