test
This commit is contained in:
parent
99597f6a72
commit
ad597b35ab
10
workers.go
10
workers.go
@ -609,11 +609,11 @@ func SQLJobWorker() {
|
|||||||
for true {
|
for true {
|
||||||
jobs, err := loadCurrentJobs()
|
jobs, err := loadCurrentJobs()
|
||||||
logOnError(err, "SQLJobWorker : loadCurrentJobs")
|
logOnError(err, "SQLJobWorker : loadCurrentJobs")
|
||||||
/*
|
|
||||||
if len(jobs) > 0 {
|
if len(jobs) > 0 {
|
||||||
log.Printf("SQLJobWorker : %d jobs.\n", len(jobs))
|
log.Printf("SQLJobWorker : %d jobs.\n", len(jobs))
|
||||||
}
|
}
|
||||||
*/
|
|
||||||
if err == nil {
|
if err == nil {
|
||||||
for _, j := range jobs {
|
for _, j := range jobs {
|
||||||
JobQueue <- j
|
JobQueue <- j
|
||||||
|
Loading…
Reference in New Issue
Block a user