diff --git a/cmd/state/exec22/txtask.go b/cmd/state/exec22/txtask.go index 97b8425e6..135303cb7 100644 --- a/cmd/state/exec22/txtask.go +++ b/cmd/state/exec22/txtask.go @@ -237,6 +237,7 @@ func (q *QueueWithRetry) NewTasksFinish() { return } q.newTasksClosed = true + log.Warn("[dbg] closing newTasks") close(q.newTasks) }