Add pipecd builtin tags to ECS resources

pkg/app/piped/executor/ecs/ecs.go

@@ -92,6 +92,11 @@ func loadServiceDefinition(in *executor.Input, serviceDefinitionFile string, ds
 		return types.Service{}, false
 	}
 
+	serviceDefinition.Tags = append(
+		serviceDefinition.Tags,
+		provider.CreateTags(map[string]string{provider.LabelApplication: in.Deployment.ApplicationId})...,
+	)
+
 	in.LogPersister.Infof("Successfully loaded the ECS service definition at commit %s", ds.Revision)
 	return serviceDefinition, true
 }
@@ -172,6 +177,7 @@ func runStandaloneTask(
 	}
 
 	in.LogPersister.Infof("Start applying the ECS task definition")
+	tags := provider.CreateTags(map[string]string{provider.LabelApplication: in.Application.Id})
 	td, err := applyTaskDefinition(ctx, client, taskDefinition)
 	if err != nil {
 		in.LogPersister.Errorf("Failed to apply ECS task definition: %v", err)
@@ -184,6 +190,7 @@ func runStandaloneTask(
 		ecsInput.ClusterArn,
 		ecsInput.LaunchType,
 		&ecsInput.AwsVpcConfiguration,
+		tags,
 	)
 	if err != nil {
 		in.LogPersister.Errorf("Failed to run ECS task: %v", err)

pkg/app/piped/platformprovider/ecs/client.go

@@ -92,7 +92,6 @@ func (c *client) CreateService(ctx context.Context, service types.Service) (*typ
 		ServiceRegistries:             service.ServiceRegistries,
 		Tags:                          service.Tags,
 	}
-
 	output, err := c.ecsClient.CreateService(ctx, input)
 	if err != nil {
 		return nil, fmt.Errorf("failed to create ECS service %s: %w", *service.ServiceName, err)
@@ -151,7 +150,7 @@ func (c *client) RegisterTaskDefinition(ctx context.Context, taskDefinition type
 	return output.TaskDefinition, nil
 }
 
-func (c *client) RunTask(ctx context.Context, taskDefinition types.TaskDefinition, clusterArn string, launchType string, awsVpcConfiguration *appconfig.ECSVpcConfiguration) error {
+func (c *client) RunTask(ctx context.Context, taskDefinition types.TaskDefinition, clusterArn string, launchType string, awsVpcConfiguration *appconfig.ECSVpcConfiguration, tags []types.Tag) error {
 	if taskDefinition.TaskDefinitionArn == nil {
 		return fmt.Errorf("failed to run task of task family %s: no task definition provided", *taskDefinition.Family)
 	}
@@ -160,6 +159,7 @@ func (c *client) RunTask(ctx context.Context, taskDefinition types.TaskDefinitio
 		TaskDefinition: taskDefinition.Family,
 		Cluster:        aws.String(clusterArn),
 		LaunchType:     types.LaunchType(launchType),
+		Tags:           tags,
 	}
 
 	if len(awsVpcConfiguration.Subnets) > 0 {

pkg/app/piped/platformprovider/ecs/ecs.go

@@ -19,13 +19,18 @@ import (
 	"path/filepath"
 	"sync"
 
+	"github.com/aws/aws-sdk-go-v2/aws"
 	"github.com/aws/aws-sdk-go-v2/service/ecs/types"
 	"go.uber.org/zap"
 	"golang.org/x/sync/singleflight"
 
 	"github.com/pipe-cd/pipecd/pkg/config"
 )
 
+const (
+	LabelApplication string = "pipecd-dev-application" // The application this resource belongs to.
+)
+
 // Client is wrapper of ECS client.
 type Client interface {
 	ECS
@@ -37,7 +42,7 @@ type ECS interface {
 	CreateService(ctx context.Context, service types.Service) (*types.Service, error)
 	UpdateService(ctx context.Context, service types.Service) (*types.Service, error)
 	RegisterTaskDefinition(ctx context.Context, taskDefinition types.TaskDefinition) (*types.TaskDefinition, error)
-	RunTask(ctx context.Context, taskDefinition types.TaskDefinition, clusterArn string, launchType string, awsVpcConfiguration *config.ECSVpcConfiguration) error
+	RunTask(ctx context.Context, taskDefinition types.TaskDefinition, clusterArn string, launchType string, awsVpcConfiguration *config.ECSVpcConfiguration, tags []types.Tag) error
 	GetPrimaryTaskSet(ctx context.Context, service types.Service) (*types.TaskSet, error)
 	CreateTaskSet(ctx context.Context, service types.Service, taskDefinition types.TaskDefinition, targetGroup *types.LoadBalancer, scale int) (*types.TaskSet, error)
 	DeleteTaskSet(ctx context.Context, service types.Service, taskSetArn string) error
@@ -109,3 +114,11 @@ var defaultRegistry = &registry{
 func DefaultRegistry() Registry {
 	return defaultRegistry
 }
+
+func CreateTags(keyValue map[string]string) []types.Tag {
+	tags := make([]types.Tag, 0, len(keyValue))
+	for key, value := range keyValue {
+		tags = append(tags, types.Tag{Key: aws.String(key), Value: aws.String(value)})
+	}
+	return tags
+}