Skip to content

Commit

Permalink
Bugfix: Use BatchJobName instead of JobName
Browse files Browse the repository at this point in the history
  • Loading branch information
Richard87 committed Sep 5, 2024
1 parent e1b0d0e commit e6c8fc5
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions api/environments/job_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -113,7 +113,7 @@ func (eh EnvironmentHandler) RestartJob(ctx context.Context, appName, envName, j
if err != nil {
return err
}
if _, err = findJobInRadixBatch(radixBatch, jobName); err != nil {
if _, err = findJobInRadixBatch(radixBatch, batchJobName); err != nil {
return err
}
return jobSchedulerBatch.RestartRadixBatchJob(ctx, eh.accounts.UserAccount.RadixClient, radixBatch, batchJobName)
Expand Down Expand Up @@ -282,11 +282,11 @@ func getActiveRadixDeployment(appName string, envName string, radixDeploymentMap
return nil, fmt.Errorf("no active deployment found for the app %s, environment %s", appName, envName)
}

func findJobInRadixBatch(radixBatch *radixv1.RadixBatch, jobName string) (*radixv1.RadixBatchJob, error) {
if job, ok := slice.FindFirst(radixBatch.Spec.Jobs, func(job radixv1.RadixBatchJob) bool { return job.Name == jobName }); ok {
func findJobInRadixBatch(radixBatch *radixv1.RadixBatch, batchJobName string) (*radixv1.RadixBatchJob, error) {
if job, ok := slice.FindFirst(radixBatch.Spec.Jobs, func(job radixv1.RadixBatchJob) bool { return job.Name == batchJobName }); ok {
return &job, nil
}
return nil, jobNotFoundError(jobName)
return nil, jobNotFoundError(batchJobName)
}

func (eh EnvironmentHandler) getDeploymentMapAndDeployJobComponents(ctx context.Context, appName string, envName string, jobComponentName string, radixBatch *radixv1.RadixBatch) (map[string]radixv1.RadixDeployment, *radixv1.RadixDeployJobComponent, *radixv1.RadixDeployJobComponent, error) {
Expand Down

0 comments on commit e6c8fc5

Please sign in to comment.