Write abort event for aborted k8s workflows

flyteorg · Sep 30, 2024 · c7c6301 · c7c6301
1 parent bcba038
commit c7c6301
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/flyteadmin/pkg/workflowengine/impl/k8s_executor.go b/flyteadmin/pkg/workflowengine/impl/k8s_executor.go
@@ -107,7 +107,7 @@ func (e K8sWorkflowExecutor) Abort(ctx context.Context, data interfaces.AbortDat
 		return errors.NewFlyteAdminErrorf(codes.Internal, "failed to terminate execution: %v with err %v", data.ExecutionID, err)
 	}
 
-	e.executionEventWriter.Write(&admin.WorkflowExecutionEventRequest{
+	e.executionEventWriter.Write(admin.WorkflowExecutionEventRequest{
 		Event: &event.WorkflowExecutionEvent{
 			ExecutionId: &core.WorkflowExecutionIdentifier{
 				Project: data.ExecutionID.Project,