Display and Update experiment description in aim UI

pkg/api/aim/experiments.go

@@ -10,6 +10,7 @@ import (
 	log "github.com/sirupsen/logrus"
 	"gorm.io/gorm"
 
+	"github.com/G-Research/fasttrackml/pkg/api/aim/request"
 	"github.com/G-Research/fasttrackml/pkg/api/mlflow/api"
 	"github.com/G-Research/fasttrackml/pkg/api/mlflow/common"
 	"github.com/G-Research/fasttrackml/pkg/api/mlflow/dao/models"
@@ -27,7 +28,8 @@ func GetExperiments(c *fiber.Ctx) error {
 
 	var experiments []struct {
 		database.Experiment
-		RunCount int
+		RunCount    int
+		Description string `gorm:"column:description"`
 	}
 	if tx := database.DB.Model(&database.Experiment{}).
 		Select(
@@ -36,10 +38,13 @@ func GetExperiments(c *fiber.Ctx) error {
 			"experiments.lifecycle_stage",
 			"experiments.creation_time",
 			"COUNT(runs.run_uuid) AS run_count",
+			"COALESCE(MAX(experiment_tags.value), '') AS description",
 		).
 		Where("experiments.namespace_id = ?", ns.ID).
 		Where("experiments.lifecycle_stage = ?", database.LifecycleStageActive).
 		Joins("LEFT JOIN runs USING(experiment_id)").
+		Joins("LEFT JOIN experiment_tags ON experiments.experiment_id = experiment_tags.experiment_id AND"+
+			" experiment_tags.key = ?", common.DescriptionTagKey).
 		Group("experiments.experiment_id").
 		Find(&experiments); tx.Error != nil {
 		return fmt.Errorf("error fetching experiments: %w", tx.Error)
@@ -50,7 +55,7 @@ func GetExperiments(c *fiber.Ctx) error {
 		resp[i] = fiber.Map{
 			"id":            strconv.Itoa(int(*e.ID)),
 			"name":          e.Name,
-			"description":   nil,
+			"description":   e.Description,
 			"archived":      e.LifecycleStage == database.LifecycleStageDeleted,
 			"run_count":     e.RunCount,
 			"creation_time": float64(e.CreationTime.Int64) / 1000,
@@ -92,7 +97,8 @@ func GetExperiment(c *fiber.Ctx) error {
 
 	var exp struct {
 		database.Experiment
-		RunCount int
+		RunCount    int
+		Description string `gorm:"column:description"`
 	}
 	if err := database.DB.Model(&database.Experiment{}).
 		Select(
@@ -101,22 +107,24 @@ func GetExperiment(c *fiber.Ctx) error {
 			"experiments.lifecycle_stage",
 			"experiments.creation_time",
 			"COUNT(runs.run_uuid) AS run_count",
+			"COALESCE(MAX(experiment_tags.value), '') AS description",
 		).
 		Joins("LEFT JOIN runs USING(experiment_id)").
-		Group("experiments.experiment_id").
+		Joins("LEFT JOIN experiment_tags ON experiments.experiment_id = experiment_tags.experiment_id AND"+
+			" experiment_tags.key = ?", common.DescriptionTagKey).
 		Where("experiments.namespace_id = ?", ns.ID).
 		Where("experiments.experiment_id = ?", id).
+		Group("experiments.experiment_id").
 		First(&exp).Error; err != nil {
 		if errors.Is(err, gorm.ErrRecordNotFound) {
 			return fiber.ErrNotFound
 		}
 		return fmt.Errorf("error fetching experiment %q: %w", p.ID, err)
 	}
-
 	return c.JSON(fiber.Map{
 		"id":            strconv.Itoa(int(id)),
 		"name":          exp.Name,
-		"description":   nil,
+		"description":   exp.Description,
 		"archived":      exp.LifecycleStage == database.LifecycleStageDeleted,
 		"run_count":     exp.RunCount,
 		"creation_time": float64(exp.CreationTime.Int64) / 1000,
@@ -327,3 +335,77 @@ func DeleteExperiment(c *fiber.Ctx) error {
 		"status": "OK",
 	})
 }
+
+func UpdateExperiment(c *fiber.Ctx) error {
+	ns, err := namespace.GetNamespaceFromContext(c.Context())
+	if err != nil {
+		return api.NewInternalError("error getting namespace from context")
+	}
+	log.Debugf("updateExperiment namespace: %s", ns.Code)
+
+	params := struct {
+		ID string `params:"id"`
+	}{}
+	if err = c.ParamsParser(&params); err != nil {
+		return fiber.NewError(fiber.StatusUnprocessableEntity, err.Error())
+	}
+	id, err := strconv.ParseInt(params.ID, 10, 32)
+	if err != nil {
+		return api.NewBadRequestError("Unable to parse experiment id '%s': %s", params.ID, err)
+	}
+
+	var updateRequest request.UpdateExperimentRequest
+	if err = c.BodyParser(&updateRequest); err != nil {
+		return fiber.NewError(fiber.StatusUnprocessableEntity, err.Error())
+	}
+
+	experimentRepository := repositories.NewExperimentRepository(database.DB)
+	tagRepository := repositories.NewTagRepository(database.DB)
+	experiment, err := experimentRepository.GetByNamespaceIDAndExperimentID(c.Context(), ns.ID, int32(id))
+	if err != nil {
+		return fiber.NewError(
+			fiber.StatusInternalServerError, fmt.Sprintf("unable to find experiment '%s': %s", params.ID, err),
+		)
+	}
+	if experiment == nil {
+		return fiber.NewError(fiber.StatusNotFound, fmt.Sprintf("unable to find experiment '%s'", params.ID))
+	}
+	if updateRequest.Archived != nil {
+		if *updateRequest.Archived {
+			experiment.LifecycleStage = models.LifecycleStageDeleted
+		} else {
+			experiment.LifecycleStage = models.LifecycleStageActive
+		}
+	}
+
+	if updateRequest.Name != nil {
+		experiment.Name = *updateRequest.Name
+	}
+
+	if updateRequest.Archived != nil || updateRequest.Name != nil {
+		if err := database.DB.Transaction(func(tx *gorm.DB) error {
+			if err := experimentRepository.UpdateWithTransaction(c.Context(), tx, experiment); err != nil {
+				return err
+			}
+			return nil
+		}); err != nil {
+			return fiber.NewError(fiber.StatusInternalServerError,
+				fmt.Sprintf("unable to update experiment %q: %s", params.ID, err))
+		}
+	}
+	if updateRequest.Description != nil {
+		description := models.ExperimentTag{
+			Key:          common.DescriptionTagKey,
+			Value:        *updateRequest.Description,
+			ExperimentID: *experiment.ID,
+		}
+		if err := tagRepository.CreateExperimentTag(c.Context(), &description); err != nil {
+			return err
+		}
+	}
+
+	return c.JSON(fiber.Map{
+		"id":     params.ID,
+		"status": "OK",
+	})
+}

pkg/api/aim/request/experiment.go

@@ -0,0 +1,8 @@
+package request
+
+// UpdateExperimentRequest is a request struct for `PUT /experiments/:id` endpoint.
+type UpdateExperimentRequest struct {
+	Name        *string `json:"name"`
+	Description *string `json:"description"`
+	Archived    *bool   `json:"archived"`
+}

pkg/api/aim/routes.go

@@ -25,6 +25,7 @@ func AddRoutes(r fiber.Router) {
 	experiments.Get("/:id/activity/", GetExperimentActivity)
 	experiments.Get("/:id/runs/", GetExperimentRuns)
 	experiments.Delete("/:id/", DeleteExperiment)
+	experiments.Put("/:id/", UpdateExperiment)
 
 	projects := r.Group("/projects")
 	projects.Get("/", GetProject)

pkg/api/mlflow/common/constants.go

@@ -6,3 +6,8 @@ const (
 	NANPositiveInfinity = "Infinity"
 	NANNegativeInfinity = "-Infinity"
 )
+
+// Constants for experiment tags keys.
+const (
+	DescriptionTagKey = "mlflow.note.content"
+)

pkg/api/mlflow/dao/repositories/experiment.go

@@ -28,6 +28,8 @@ type ExperimentRepositoryProvider interface {
 	GetByNamespaceIDAndExperimentID(
 		ctx context.Context, namespaceID uint, experimentID int32,
 	) (*models.Experiment, error)
+	// UpdateWithTransaction updates existing models.Experiment entity in scope of transaction.
+	UpdateWithTransaction(ctx context.Context, tx *gorm.DB, experiment *models.Experiment) error
 }
 
 // ExperimentRepository repository to work with `experiment` entity.
@@ -175,3 +177,16 @@ func (r ExperimentRepository) DeleteBatch(ctx context.Context, ids []*int32) err
 
 	return nil
 }
+
+// UpdateWithTransaction updates existing models.Experiment entity in scope of transaction.
+func (r ExperimentRepository) UpdateWithTransaction(
+	ctx context.Context,
+	tx *gorm.DB,
+	experiment *models.Experiment,
+) error {
+	if err := tx.WithContext(ctx).Model(&experiment).Updates(experiment).Error; err != nil {
+		return eris.Wrapf(err, "error updating existing experiment with id: %d", experiment.ID)
+	}
+
+	return nil
+}

tests/integration/golang/aim/experiment/get_experiment_test.go

@@ -42,7 +42,7 @@ func (s *GetExperimentTestSuite) Test_Ok() {
 		Name: "Test Experiment",
 		Tags: []models.ExperimentTag{
 			{
-				Key:   "key1",
+				Key:   common.DescriptionTagKey,
 				Value: "value1",
 			},
 		},
@@ -61,11 +61,12 @@ func (s *GetExperimentTestSuite) Test_Ok() {
 	s.Require().Nil(err)
 
 	var resp response.GetExperiment
+
 	s.Require().Nil(s.AIMClient().WithResponse(&resp).DoRequest("/experiments/%d", *experiment.ID))
 
 	s.Equal(fmt.Sprintf("%d", *experiment.ID), resp.ID)
 	s.Equal(experiment.Name, resp.Name)
-	s.Equal("", resp.Description)
+	s.Equal(helpers.GetDescriptionFromExperiment(*experiment), resp.Description)
 	s.Equal(float64(experiment.CreationTime.Int64)/1000, resp.CreationTime)
 	s.Equal(false, resp.Archived)
 	s.Equal(len(experiment.Runs), resp.RunCount)

tests/integration/golang/aim/experiment/get_experiments_test.go

@@ -22,7 +22,7 @@ type GetExperimentsTestSuite struct {
 }
 
 func TestGetExperimentsTestSuite(t *testing.T) {
-	suite.Run(t, new(GetExperimentTestSuite))
+	suite.Run(t, new(GetExperimentsTestSuite))
 }
 
 func (s *GetExperimentsTestSuite) Test_Ok() {
@@ -74,5 +74,7 @@ func (s *GetExperimentsTestSuite) Test_Ok() {
 		s.Equal(float64(expectedExperiment.CreationTime.Int64)/1000, actualExperiment.CreationTime)
 		s.Equal(expectedExperiment.LifecycleStage == models.LifecycleStageDeleted, actualExperiment.Archived)
 		s.Equal(len(expectedExperiment.Runs), actualExperiment.RunCount)
+		s.Equal(helpers.GetDescriptionFromExperiment(*expectedExperiment), actualExperiment.Description)
+
 	}
 }

tests/integration/golang/helpers/experiment.go

@@ -0,0 +1,16 @@
+package helpers
+
+import (
+	"github.com/G-Research/fasttrackml/pkg/api/mlflow/common"
+	"github.com/G-Research/fasttrackml/pkg/api/mlflow/dao/models"
+)
+
+// GetDescriptionFromexperiment returns the description of a given experiment.
+func GetDescriptionFromExperiment(experiment models.Experiment) string {
+	for _, tag := range experiment.Tags {
+		if tag.Key == common.DescriptionTagKey {
+			return tag.Value
+		}
+	}
+	return ""
+}