Method OnPersisted

pkg/queue/task.go:287–292

(task *ent.Task)

}

func (t *DBTask) OnPersisted(task *ent.Task) {
	t.mu.Lock()
	defer t.mu.Unlock()

	t.Task = task
}

func (t *DBTask) OnError(err error, d time.Duration) {
	t.mu.Lock()