ovh
diff --git a/‎engine/api/event/publish_workflow_run.go
Lines changed: 1 addition & 0 deletions b/‎engine/api/event/publish_workflow_run.go
Lines changed: 1 addition & 0 deletions
diff --git a/‎sdk/event.go
Lines changed: 1 addition & 0 deletions b/‎sdk/event.go
Lines changed: 1 addition & 0 deletions
@@ -102,6 +102,7 @@ func PublishWorkflowNodeRun(db gorp.SqlExecutor, nr sdk.WorkflowNodeRun, w sdk.W
 		if wnode.Context != nil && wnode.Context.EnvironmentID != 0 {
 			env = w.Environments[wnode.Context.EnvironmentID]
 		}
+		e.NodeType = wnode.Type
 	} else {
 		nodeName = n.Name
 		pipName = w.Pipelines[n.PipelineID].Name
 
@@ -79,6 +79,7 @@ type EventRunWorkflowNode struct {
 	StagesSummary         []StageSummary            `json:"stages_summary"`
 	HookUUID              string                    `json:"hook_uuid"`
 	HookLog               string                    `json:"log,omitempty"`
+	NodeType              string                    `json:"node_type,omitempty"`
 }
 
 // EventRunWorkflowOutgoingHook contains event data for a workflow outgoing hook run
Original file line number	Diff line number	Diff line change
`@@ -102,6 +102,7 @@ func PublishWorkflowNodeRun(db gorp.SqlExecutor, nr sdk.WorkflowNodeRun, w sdk.W`
`102`	`102`	`if wnode.Context != nil && wnode.Context.EnvironmentID != 0 {`
`103`	`103`	`env = w.Environments[wnode.Context.EnvironmentID]`
`104`	`104`	`}`
	`105`	`+ e.NodeType = wnode.Type`
`105`	`106`	`} else {`
`106`	`107`	`nodeName = n.Name`
`107`	`108`	`pipName = w.Pipelines[n.PipelineID].Name`
Original file line number	Diff line number	Diff line change
`@@ -79,6 +79,7 @@ type EventRunWorkflowNode struct {`
`79`	`79`	StagesSummary []StageSummary `json:"stages_summary"`
`80`	`80`	HookUUID string `json:"hook_uuid"`
`81`	`81`	HookLog string `json:"log,omitempty"`
	`82`	+ NodeType string `json:"node_type,omitempty"`
`82`	`83`	`}`
`83`	`84`
`84`	`85`	`// EventRunWorkflowOutgoingHook contains event data for a workflow outgoing hook run`