Method CreateTaskRunLog

backend/store/task_run_log.go:28–58

(ctx context.Context, projectID string, taskRunUID int64, t time.Time, replicaID string, e *storepb.TaskRunLog)

}

func (s *Store) CreateTaskRunLog(ctx context.Context, projectID string, taskRunUID int64, t time.Time, replicaID string, e *storepb.TaskRunLog) error {
	e.ReplicaId = replicaID
	p, err := protojson.Marshal(e)
	if err != nil {
		return errors.Wrapf(err, "failed to marshal task run log")
	}

	q := qb.Q().Space(`
		INSERT INTO task_run_log (
			project,
			task_run_id,
			created_at,
			payload
		) VALUES (
			?,
			?,
			?,
			?
		)
	`, projectID, taskRunUID, t, p)

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

	if _, err := s.GetDB().ExecContext(ctx, sql, args...); err != nil {
		return errors.Wrapf(err, "failed to create task run log")
	}
	return nil
}

func (s *Store) ListTaskRunLogs(ctx context.Context, projectID string, taskRunUID int64) ([]*TaskRunLog, error) {
	q := qb.Q().Space(`