Method FindBlockingTaskByVersion

backend/store/task.go:97–153

Get a blocking task in the pipeline. A task is blocked by a task with a smaller schema version within the same pipeline.

(ctx context.Context, projectID string, planUID int64, instanceID, databaseName string, version string)

// Get a blocking task in the pipeline.
// A task is blocked by a task with a smaller schema version within the same pipeline.
func (s *Store) FindBlockingTaskByVersion(ctx context.Context, projectID string, planUID int64, instanceID, databaseName string, version string) (*int64, error) {
	myVersion, err := model.NewVersion(version)
	if err != nil {
		return nil, err
	}
	q := qb.Q().Space(`
		SELECT
			task.id,
			task.payload->>'schemaVersion'
		FROM task
		LEFT JOIN plan ON plan.project = task.project AND plan.id = task.plan_id
		LEFT JOIN issue ON issue.project = plan.project AND issue.plan_id = plan.id
		LEFT JOIN LATERAL (
			SELECT COALESCE(
				(SELECT
					task_run.status
				FROM task_run
				WHERE task_run.project = task.project AND task_run.task_id = task.id
				ORDER BY task_run.id DESC
				LIMIT 1
			), 'NOT_STARTED'
			) AS status
		) AS latest_task_run ON TRUE
		WHERE task.project = ? AND task.plan_id = ? AND task.instance = ? AND task.db_name = ?
		AND task.payload->>'schemaVersion' IS NOT NULL
		AND (task.payload->>'skipped')::BOOLEAN IS NOT TRUE
		AND latest_task_run.status != 'DONE'
		AND COALESCE(issue.status, 'OPEN') = 'OPEN'
		ORDER BY task.id ASC`, projectID, planUID, instanceID, databaseName)
	query, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}
	rows, err := s.GetDB().QueryContext(ctx, query, args...)
	if err != nil {
		return nil, err
	}
	defer rows.Close()
	for rows.Next() {
		var id int64
		var v string
		if err := rows.Scan(&id, &v); err != nil {
			return nil, errors.Wrapf(err, "failed to scan rows")
		}
		otherVersion, err := model.NewVersion(v)
		if err != nil {
			return nil, err
		}
		if otherVersion.LessThan(myVersion) {
			return &id, nil
		}
	}
	if rows.Err() != nil {
		return nil, rows.Err()
	}
	return nil, nil
}