fix: update job.Runs function to include environment parameter

Author: rbjornstad

internal/graph/jobs.resolvers.go

@@ -50,7 +50,7 @@ func (r *jobResolver) Runs(ctx context.Context, obj *job.Job, first *int, after
 		return nil, err
 	}
 
-	return job.Runs(ctx, obj.TeamSlug, obj.Name, page)
+	return job.Runs(ctx, obj.TeamSlug, obj.EnvironmentName, obj.Name, page)
 }
 
 func (r *jobResolver) Manifest(ctx context.Context, obj *job.Job) (*job.JobManifest, error) {

internal/status/check_job_runs.go

@@ -22,7 +22,7 @@ func (c checkJobRuns) Run(ctx context.Context, w workload.Workload) ([]WorkloadS
 
 func (checkJobRuns) run(ctx context.Context, w workload.Workload) WorkloadStatusError {
 	page, _ := pagination.ParsePage(ptr.To(5), nil, nil, nil)
-	runs, err := job.Runs(ctx, w.GetTeamSlug(), w.GetName(), page)
+	runs, err := job.Runs(ctx, w.GetTeamSlug(), w.GetEnvironmentName(), w.GetName(), page)
 	if err != nil {
 		// TODO(chredvar): Unable to create label selector above, log?
 		return &WorkloadStatusSynchronizationFailing{

internal/workload/job/queries.go

@@ -103,15 +103,16 @@ func getJobRunInstanceByIdent(ctx context.Context, id ident.Ident) (*JobRunInsta
 	return toGraphJobRunInstance(pod, env), nil
 }
 
-func Runs(ctx context.Context, teamSlug slug.Slug, jobName string, page *pagination.Pagination) (*JobRunConnection, error) {
+func Runs(ctx context.Context, teamSlug slug.Slug, environment, jobName string, page *pagination.Pagination) (*JobRunConnection, error) {
 	nameReq, err := labels.NewRequirement("app", selection.Equals, []string{jobName})
 	if err != nil {
 		return nil, err
 	}
 
 	selector := labels.NewSelector().Add(*nameReq)
 
-	allRuns := fromContext(ctx).runWatcher.GetByNamespace(teamSlug.String(), watcher.WithLabels(selector))
+	allRuns := fromContext(ctx).runWatcher.GetByNamespace(teamSlug.String(), watcher.InCluster(environment), watcher.WithLabels(selector))
+
 	ret := make([]*JobRun, len(allRuns))
 	for i, run := range allRuns {
 		ret[i] = toGraphJobRun(run.Obj, run.Cluster)