Method ListTaskRunLogs

backend/store/task_run_log.go:60–106

(ctx context.Context, projectID string, taskRunUID int64)

}

func (s *Store) ListTaskRunLogs(ctx context.Context, projectID string, taskRunUID int64) ([]*TaskRunLog, error) {
	q := qb.Q().Space(`
		SELECT
			created_at,
			payload
		FROM task_run_log
		WHERE task_run_log.project = ? AND task_run_log.task_run_id = ?
		ORDER BY created_at
	`, projectID, taskRunUID)

	sql, args, err := q.ToSQL()
	if err != nil {
		return nil, errors.Wrapf(err, "failed to build sql")
	}

	rows, err := s.GetDB().QueryContext(ctx, sql, args...)
	if err != nil {
		return nil, errors.Wrapf(err, "failed to query task run log")
	}
	defer rows.Close()

	var logs []*TaskRunLog
	for rows.Next() {
		l := TaskRunLog{
			Payload: &storepb.TaskRunLog{},
		}
		var p []byte

		if err := rows.Scan(
			&l.T,
			&p,
		); err != nil {
			return nil, errors.Wrapf(err, "failed to scan")
		}

		if err := common.ProtojsonUnmarshaler.Unmarshal(p, l.Payload); err != nil {
			return nil, errors.Wrapf(err, "failed to unmarshal")
		}

		logs = append(logs, &l)
	}
	if err := rows.Err(); err != nil {
		return nil, errors.Wrapf(err, "failed to query")
	}

	return logs, nil
}