chtwrs/chirpnest
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
shoopea 2020-10-20 11:47:13 +02:00
parent 9640058f1c
commit 9929fb7997
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
sql.go
View File

@ -1013,7 +1013,7 @@ func cleanupJobData() {
if err != nil { if err != nil {
return return
} }
log.Printf("cleanupJobData : JobID : %d\n", jobID) // log.Printf("cleanupJobData : JobID : %d\n", jobID)
err = doneStmt.QueryRow(jobID).Scan(&isDone) err = doneStmt.QueryRow(jobID).Scan(&isDone)
if err != nil { if err != nil {
@ -1029,13 +1029,13 @@ func cleanupJobData() {
return return
} }
countObjDeleted += del countObjDeleted += del
log.Printf("cleanupJobData : delObj : %d\n", del) // log.Printf("cleanupJobData : delObj : %d\n", del)
} else { } else {
logOnError(err, "cleanupJobData : scan doneStmt") logOnError(err, "cleanupJobData : scan doneStmt")
return return
} }
} else { } else {
log.Printf("cleanupJobData : isDone : %d\n", isDone) // log.Printf("cleanupJobData : isDone : %d\n", isDone)
if isDone == 1 { if isDone == 1 {
delJob, err := delJobStmt.Exec(jobID) delJob, err := delJobStmt.Exec(jobID)
logOnError(err, "cleanupJobData : exec delJobStmt") logOnError(err, "cleanupJobData : exec delJobStmt")
@ -1052,7 +1052,7 @@ func cleanupJobData() {
return return
} }
countJobDeleted += del countJobDeleted += del
log.Printf("cleanupJobData : delJob : %d\n", del) /// log.Printf("cleanupJobData : delJob : %d\n", del)
} }
} }
} }