fix
This commit is contained in:
parent
56fe67649a
commit
ea26736eba
8
sql.go
8
sql.go
@ -1013,12 +1013,16 @@ func cleanupJobData() {
|
|||||||
}
|
}
|
||||||
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)
|
||||||
logOnError(err, "cleanupJobData : scan doneStmt")
|
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if err.Error() == `sql: no rows in result set` {
|
if err.Error() == `sql: no rows in result set` {
|
||||||
|
delObj, err := delObjStmt.Exec(jobID)
|
||||||
|
logOnError(err, "cleanupJobData : exec delObjStmt")
|
||||||
|
if err != nil {
|
||||||
|
return
|
||||||
|
}
|
||||||
} else {
|
} else {
|
||||||
|
logOnError(err, "cleanupJobData : scan doneStmt")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
Reference in New Issue
Block a user