Method Retried

pkg/queue/task.go:229–237

()

}

func (t *DBTask) Retried() int {
	t.mu.Lock()
	defer t.mu.Unlock()

	if t.Task != nil {
		return t.Task.PublicState.RetryCount
	}
	return 0
}

func (t *DBTask) Error() error {
	t.mu.Lock()