This commit is contained in:
alex.sharov 2023-04-19 13:00:13 +07:00
parent 8a7f9b5163
commit e308cfbdf8

View File

@ -237,6 +237,7 @@ func (q *QueueWithRetry) NewTasksFinish() {
return
}
q.newTasksClosed = true
log.Warn("[dbg] closing newTasks")
close(q.newTasks)
}