Function GetSubTasksInfo

backend/server/services/task.go:242–333

GetSubTasksInfo returns subtask list of the pipeline, only the most recently subtasks would be returned

(pipelineId uint64, shouldSanitize bool, tx dal.Dal)

// GetSubTasksInfo returns subtask list of the pipeline, only the most recently subtasks would be returned
func GetSubTasksInfo(pipelineId uint64, shouldSanitize bool, tx dal.Dal) (*models.SubTasksOuput, errors.Error) {
	if tx == nil {
		tx = db
	}
	var tasks []*models.Task
	err := tx.All(&tasks, dal.Where("pipeline_id = ?", pipelineId), dal.Orderby("id"))
	if err != nil {
		return nil, err
	}

	lastTasks := filterTasksWithLastStatus(tasks)
	var subtasksInfo []models.SubtasksInfo
	var totalSubtasksCount int64
	var totalFinishedSubTasksCount int64
	var count int64
	var status []string
	for _, task := range lastTasks {
		if task.Plugin == "org" || task.Plugin == "refdiff" || task.Plugin == "dora" {
			continue
		}
		subTaskResult := models.SubtasksInfo{
			ID:           task.ID,
			PipelineID:   task.PipelineId,
			CreatedAt:    task.CreatedAt,
			UpdatedAt:    task.UpdatedAt,
			BeganAt:      task.BeganAt,
			FinishedAt:   task.FinishedAt,
			Plugin:       task.Plugin,
			Status:       task.Status,
			Message:      task.Message,
			ErrorName:    task.ErrorName,
			SpentSeconds: task.SpentSeconds,
		}
		if shouldSanitize {
			taskOption, err := SanitizePluginOption(task.Plugin, task.Options)
			if err != nil {
				return nil, errors.Convert(err)
			}
			subTaskResult.Options = taskOption
		}

		subtasks := []*models.Subtask{}
		err = tx.All(&subtasks, dal.Where("task_id = ?", task.ID))
		if err != nil {
			return nil, err
		}
		for _, subtask := range subtasks {
			t := &models.SubtaskDetails{
				ID:              subtask.ID,
				CreatedAt:       subtask.CreatedAt,
				UpdatedAt:       subtask.UpdatedAt,
				TaskID:          subtask.TaskID,
				Name:            subtask.Name,
				Number:          subtask.Number,
				BeganAt:         subtask.BeganAt,
				FinishedAt:      subtask.FinishedAt,
				SpentSeconds:    subtask.SpentSeconds,
				FinishedRecords: subtask.FinishedRecords,