Method ProcessResult

pkg/task/queue/task_storage.go:251–268

(taskRes TaskResult, t task.Task)

}

func (ts *TaskStorage) ProcessResult(taskRes TaskResult, t task.Task) {
	ts.mu.Lock()
	defer ts.mu.Unlock()

	// Add after tasks
	ts.addAfter(t.GetId(), taskRes.GetAfterTasks()...)

	// Remove the current task if successful
	if taskRes.Status == Success {
		ts.remove(t.GetId())
	}

	// Add head tasks
	ts.addFirst(taskRes.GetHeadTasks()...)

	// Add tail tasks to the end
	ts.addLast(taskRes.GetTailTasks()...)
}