diff --git a/probe/awsecs/reporter.go b/probe/awsecs/reporter.go index 5e4849ce0a..9980b321af 100644 --- a/probe/awsecs/reporter.go +++ b/probe/awsecs/reporter.go @@ -184,6 +184,8 @@ func (r Reporter) Tag(rpt report.Report) (report.Report, error) { if serviceName, ok := ecsInfo.TaskServiceMap[taskArn]; ok { serviceID := report.MakeECSServiceNodeID(cluster, serviceName) parentsSets = parentsSets.Add(report.ECSService, report.MakeStringSet(serviceID)) + // in addition, make service parent of task + rpt.ECSTask.Nodes[taskID] = rpt.ECSTask.Nodes[taskID].WithParents(report.MakeSets().Add(report.ECSService, report.MakeStringSet(serviceID))) } for _, containerID := range info.ContainerIDs { if containerNode, ok := rpt.Container.Nodes[containerID]; ok {