Refactor workload retrieval in kafkaTopicAclResolver

rbjornstad · rbjornstad · commit 2839324f4aa3 · 2025-02-20T13:56:51.000+01:00
diff --git a/internal/graph/kafka.resolvers.go b/internal/graph/kafka.resolvers.go
@@ -72,12 +72,7 @@ func (r *kafkaTopicAclResolver) Workload(ctx context.Context, obj *kafkatopic.Ka
 		return nil, nil
 	}
 
-	owner := &workload.Reference{
-		Type: workload.TypeApplication,
-		Name: obj.WorkloadName,
-	}
-
-	w, err := getWorkload(ctx, owner, slug.Slug(obj.TeamName), obj.EnvironmentName)
+	w, err := tryWorkload(ctx, slug.Slug(obj.TeamName), obj.EnvironmentName, obj.WorkloadName)
 	if errors.Is(err, &watcher.ErrorNotFound{}) {
 		return nil, nil
 	}

Original file line number	Diff line number	Diff line change
`@@ -72,12 +72,7 @@ func (r kafkaTopicAclResolver) Workload(ctx context.Context, obj kafkatopic.Ka`
`72`	`72`	`return nil, nil`
`73`	`73`	`}`
`74`	`74`
`75`		`- owner := &workload.Reference{`
`76`		`- Type: workload.TypeApplication,`
`77`		`- Name: obj.WorkloadName,`
`78`		`- }`
`79`		`-`
`80`		`- w, err := getWorkload(ctx, owner, slug.Slug(obj.TeamName), obj.EnvironmentName)`
	`75`	`+ w, err := tryWorkload(ctx, slug.Slug(obj.TeamName), obj.EnvironmentName, obj.WorkloadName)`
`81`	`76`	`if errors.Is(err, &watcher.ErrorNotFound{}) {`
`82`	`77`	`return nil, nil`
`83`	`78`	`}`