diff --git a/executor/workflow_manager_sfn.go b/executor/workflow_manager_sfn.go index 0be998d8..5469460d 100644 --- a/executor/workflow_manager_sfn.go +++ b/executor/workflow_manager_sfn.go @@ -393,14 +393,19 @@ func (wm *SFNWorkflowManager) UpdateWorkflowSummary(ctx context.Context, workflo return err } failedJob := "" + failedJobResource := "" if workflow.LastJob != nil { failedJob = workflow.LastJob.State + if workflow.LastJob.StateResource != nil { + failedJobResource = workflow.LastJob.StateResource.Name + } } log.CounterD("workflow-failed", 1, logger.M{ - "workflow-name": workflow.WorkflowDefinition.Name, - "workflow-version": workflow.WorkflowDefinition.Version, - "workflow-id": workflow.ID, - "failed-job-name": failedJob, + "workflow-name": workflow.WorkflowDefinition.Name, + "workflow-version": workflow.WorkflowDefinition.Version, + "workflow-id": workflow.ID, + "failed-job-name": failedJob, + "failed-job-resource": failedJobResource, }) } diff --git a/kvconfig.yml b/kvconfig.yml index 8ba65382..a5aff595 100644 --- a/kvconfig.yml +++ b/kvconfig.yml @@ -18,7 +18,7 @@ routes: output: type: "alerts" series: "workflow-manager.job-failed" - dimensions: ["workflow-name", "failed-job-name", "workflow-version"] + dimensions: ["workflow-name", "failed-job-name", "failed-job-resource", "workflow-version"] stat_type: "counter" execution-not-found-alert: