Skip to content

Commit 34f5dfb

Browse files
authored
use summaryID not job ID (#1838)
1 parent aa712e3 commit 34f5dfb

File tree

2 files changed

+5
-5
lines changed

2 files changed

+5
-5
lines changed

next/controllers/projects.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -110,7 +110,7 @@ func (d DiggerController) SetJobStatusForProject(c *gin.Context) {
110110

111111
// store digger job summary
112112
if request.JobSummary != nil {
113-
dbmodels.DB.UpdateDiggerJobSummary(job.DiggerJobID, request.JobSummary.ResourcesCreated, request.JobSummary.ResourcesUpdated, request.JobSummary.ResourcesDeleted)
113+
dbmodels.DB.UpdateDiggerJobSummary(job.DiggerJobSummaryID, request.JobSummary.ResourcesCreated, request.JobSummary.ResourcesUpdated, request.JobSummary.ResourcesDeleted)
114114
}
115115

116116
// update the project drift status

next/dbmodels/storage.go

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -930,14 +930,14 @@ WHERE
930930
return runqueuesWithData, nil
931931
}
932932

933-
func (db *Database) UpdateDiggerJobSummary(diggerJobId string, resourcesCreated uint, resourcesUpdated uint, resourcesDeleted uint) (*model.DiggerJob, error) {
934-
diggerJob, err := db.GetDiggerJob(diggerJobId)
933+
func (db *Database) UpdateDiggerJobSummary(diggerJobSummaryId string, resourcesCreated uint, resourcesUpdated uint, resourcesDeleted uint) (*model.DiggerJob, error) {
934+
diggerJob, err := db.GetDiggerJob(diggerJobSummaryId)
935935
if err != nil {
936936
return nil, fmt.Errorf("Could not get digger job")
937937
}
938938
var jobSummary *model.DiggerJobSummary
939939

940-
jobSummary, err = db.Query.DiggerJobSummary.Select(db.Query.DiggerJobSummary.ID.Eq(diggerJobId)).First()
940+
jobSummary, err = db.Query.DiggerJobSummary.Select(db.Query.DiggerJobSummary.ID.Eq(diggerJobSummaryId)).First()
941941
if err != nil {
942942
return nil, fmt.Errorf("could not get digger job summary: %v", err)
943943
}
@@ -950,7 +950,7 @@ func (db *Database) UpdateDiggerJobSummary(diggerJobId string, resourcesCreated
950950
return nil, result.Error
951951
}
952952

953-
log.Printf("DiggerJob %v summary has been updated successfully\n", diggerJobId)
953+
log.Printf("DiggerJob %v summary has been updated successfully\n", diggerJobSummaryId)
954954
return diggerJob, nil
955955
}
956956

0 commit comments

Comments
 (0)