Method UpdateTaskRunStatus

backend/store/task_run.go:208–224

UpdateTaskRunStatus updates task run status.

(ctx context.Context, patch *TaskRunStatusPatch)

// UpdateTaskRunStatus updates task run status.
func (s *Store) UpdateTaskRunStatus(ctx context.Context, patch *TaskRunStatusPatch) (*TaskRunMessage, error) {
	tx, err := s.GetDB().BeginTx(ctx, nil)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to begin tx")
	}
	defer tx.Rollback()

	taskRun, err := s.patchTaskRunStatusImpl(ctx, tx, patch)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to update task run")
	}

	if err := tx.Commit(); err != nil {
		return nil, errors.Wrapf(err, "failed to commit tx")
	}
	return taskRun, nil
}

// ClaimedTaskRun represents a claimed task run with its task UID.
type ClaimedTaskRun struct {