Skip to content

Commit

Permalink
using correct id for delete operation
Browse files Browse the repository at this point in the history
  • Loading branch information
MariusDieckmann committed May 17, 2021
1 parent 342162a commit 203ced3
Show file tree
Hide file tree
Showing 3 changed files with 3 additions and 3 deletions.
2 changes: 1 addition & 1 deletion .kube/dev-deployment.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -64,7 +64,7 @@ spec:
secretKeyRef:
key: Token
name: authhandler
image: harbor.computational.bio.uni-giessen.de/bakta/bakta-web-backend:0.2.9-beta.8
image: harbor.computational.bio.uni-giessen.de/bakta/bakta-web-backend:0.2.9-beta.9
imagePullPolicy: Always
name: baktabackend
ports:
Expand Down
2 changes: 1 addition & 1 deletion endpoints/job.go
Original file line number Diff line number Diff line change
Expand Up @@ -127,7 +127,7 @@ func (apiHandler *BaktaJobAPI) GetJobsStatus(ctx context.Context, request *api.J
}

if newStatus.Status == api.JobStatusEnum_SUCCESSFULL || newStatus.Status == api.JobStatusEnum_ERROR {
err := apiHandler.scheduler.DeleteJob(job.K8sID)
err := apiHandler.scheduler.DeleteJob(job.JobID)
if err != nil {
err = fmt.Errorf("could not get updated job status")
return nil, err
Expand Down
2 changes: 1 addition & 1 deletion endpoints/update.go
Original file line number Diff line number Diff line change
Expand Up @@ -36,7 +36,7 @@ func (apiHandler *BaktaUpdateAPI) UpdateStatus(ctx context.Context, request *api
return
}
if !job.IsDeleted {
err = apiHandler.scheduler.DeleteJob(job.K8sID)
err = apiHandler.scheduler.DeleteJob(job.JobID)
if err != nil {
log.Println(err.Error())
return
Expand Down

0 comments on commit 203ced3

Please sign in to comment.