Method Remove

pkg/task/queue/task_queue.go:674–683

Remove finds element by id and deletes it.

(id string)

// Remove finds element by id and deletes it.
func (q *TaskQueue) Remove(id string) task.Task {
	defer q.MeasureActionTime("Remove")()

	t := q.storage.Remove(id)
	if t != nil {
		q.queueTasksCounter.Remove(t)
	}

	return t
}

func (q *TaskQueue) Stop() {
	if q.cancel != nil {