Add ASSET_MATERIALIZATION_FAILURE event

test fixes

js_modules/dagster-ui/packages/ui-core/src/runs/LogsRowStructuredContent.tsx

@@ -152,6 +152,7 @@ export const LogsRowStructuredContent = ({node, metadata}: IStructuredContentPro
         />
       );
     case 'AssetMaterializationPlannedEvent':
+    case 'AssetMaterializationFailureEvent':
       return <DefaultContent eventType={eventType} message={node.message} />;
     case 'ObjectStoreOperationEvent':
       return (

js_modules/dagster-ui/packages/ui-core/src/runs/filterLogs.tsx

@@ -6,11 +6,12 @@ import {weakmapMemoize} from '../app/Util';
 
 export function filterLogs(logs: LogsProviderLogs, filter: LogFilter, filterStepKeys: string[]) {
   const filteredNodes = logs.allNodes.filter((node) => {
-    // These events are used to determine which assets a run will materialize and are not intended
+    // These events are used for internal bookkeeping and are not intended
     // to be displayed in the Dagster UI. Pagination is offset based, so we remove these logs client-side.
     if (
       node.__typename === 'AssetMaterializationPlannedEvent' ||
-      node.__typename === 'AssetCheckEvaluationPlannedEvent'
+      node.__typename === 'AssetCheckEvaluationPlannedEvent' ||
+      node.__typename === 'AssetMaterializationFailureEvent'
     ) {
       return false;
     }

python_modules/dagster-graphql/dagster_graphql/implementation/events.py

@@ -222,6 +222,7 @@ def from_dagster_event_record(event_record: EventLogEntry, pipeline_name: str) -
         GrapheneAlertSuccessEvent,
         GrapheneAssetCheckEvaluationEvent,
         GrapheneAssetCheckEvaluationPlannedEvent,
+        GrapheneAssetMaterializationFailureEvent,
         GrapheneAssetMaterializationPlannedEvent,
         GrapheneEngineEvent,
         GrapheneExecutionStepFailureEvent,
@@ -303,6 +304,8 @@ def from_dagster_event_record(event_record: EventLogEntry, pipeline_name: str) -
         )
     elif dagster_event.event_type == DagsterEventType.ASSET_MATERIALIZATION_PLANNED:
         return GrapheneAssetMaterializationPlannedEvent(event=event_record)
+    elif dagster_event.event_type == DagsterEventType.ASSET_MATERIALIZATION_FAILURE:
+        return GrapheneAssetMaterializationFailureEvent(event=event_record)
     elif dagster_event.event_type == DagsterEventType.STEP_EXPECTATION_RESULT:
         data = cast(StepExpectationResultData, dagster_event.event_specific_data)
         return GrapheneStepExpectationResultEvent(

python_modules/dagster-graphql/dagster_graphql/schema/logs/events.py

@@ -405,6 +405,20 @@ def __init__(self, event):
         )
 
 
+class GrapheneAssetMaterializationFailureEvent(graphene.ObjectType):
+    assetKey = graphene.Field(GrapheneAssetKey)
+
+    class Meta:
+        name = "AssetMaterializationFailureEvent"
+        interfaces = (GrapheneMessageEvent, GrapheneRunEvent)
+
+    def __init__(self, event: EventLogEntry):
+        self._event = event
+
+    def resolve_assetKey(self, _graphene_info: ResolveInfo):
+        return self._event.get_dagster_event().asset_materialization_failure_data.asset_key
+
+
 class GrapheneAssetMaterializationPlannedEvent(graphene.ObjectType):
     assetKey = graphene.Field(GrapheneAssetKey)
     runOrError = graphene.NonNull("dagster_graphql.schema.pipelines.pipeline.GrapheneRunOrError")
@@ -586,6 +600,7 @@ class Meta:
             GrapheneAlertSuccessEvent,
             GrapheneAlertFailureEvent,
             GrapheneAssetMaterializationPlannedEvent,
+            GrapheneAssetMaterializationFailureEvent,
             GrapheneAssetCheckEvaluationPlannedEvent,
             GrapheneAssetCheckEvaluationEvent,
         )

python_modules/dagster/dagster/_core/event_api.py

@@ -85,6 +85,7 @@ class RunShardedEventsCursor(NamedTuple):
     DagsterEventType.ASSET_MATERIALIZATION,
     DagsterEventType.ASSET_OBSERVATION,
     DagsterEventType.ASSET_MATERIALIZATION_PLANNED,
+    DagsterEventType.ASSET_MATERIALIZATION_FAILURE,
 ]
 
 EventCursor: TypeAlias = Union[int, RunShardedEventsCursor]