func taskDefFamily()

in updater/main.go [183:198]


func taskDefFamily() (string, error) {
	taskDefInput := os.Getenv(taskDefARNEnv)
	taskDefARN, err := arn.Parse(taskDefInput)
	if err != nil {
		return "", err
	}
	const taskDefPrefix = "task-definition/"
	if !strings.Contains(taskDefARN.Resource, taskDefPrefix) {
		return "", fmt.Errorf("not a task definition arn: %q", taskDefInput)
	}
	// extract task definition family from resource: task-definition/<task definition family>:<revision>
	taskDef := strings.TrimPrefix(taskDefARN.Resource, taskDefPrefix)
	family := strings.SplitN(taskDef, ":", 2)[0]
	log.Printf("Updater task definition family: %q", family)
	return family, nil
}