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
}