package dag

import (
	"github.com/tidbcloud/fastflow/pkg/entity"

	"github.com/tidbcloud/tidb-management-service/dedicated-global-service/domain/service/workflow/action"
	"github.com/tidbcloud/tidb-management-service/dedicated-global-service/domain/service/workflow/common"
)

func DeleteVpcPeeringDag() *entity.Dag {
	dag := &entity.Dag{
		BaseInfo: entity.BaseInfo{
			ID: common.DeleteVpcPeering,
		},
		Name:   common.DeleteVpcPeering,
		Status: entity.DagStatusNormal,
		Vars: map[string]entity.DagVar{
			common.KeyVpcPeeringId:      {},
			common.KeyRegionLogicalName: {},
		},
		Tasks: []entity.Task{
			{
				ID:         action.DeleteVpcPeering,
				ActionName: action.DeleteVpcPeering,
				Params:     map[string]any{},
			},
		},
	}
	return dag
}