Merge branch '309-refresh-overlapping' into 'master'

fix: check the retrieval status before running a new data refresh iteration and skip refreshing if this is already in progress (#309)

Closes #309

See merge request postgres-ai/database-lab!402

Author: agneum

internal/cloning/storage.go

@@ -112,8 +112,6 @@ func (c *Base) filterRunningClones(ctx context.Context) {
 
 // SaveClonesState writes clones state to disk.
 func (c *Base) SaveClonesState() {
-	log.Msg("Saving state of running clones")
-
 	sessionsPath, err := util.GetMetaPath(sessionsFilename)
 	if err != nil {
 		log.Err("failed to get path of a sessions file", err)
@@ -122,8 +120,6 @@ func (c *Base) SaveClonesState() {
 	if err := c.saveClonesState(sessionsPath); err != nil {
 		log.Err("Failed to save the state of running clones", err)
 	}
-
-	log.Msg("The state of running clones has been saved")
 }
 
 // saveClonesState tries to write clones state to disk and returns an error on failure.

internal/retrieval/retrieval.go

@@ -416,6 +416,18 @@ func (r *Retrieval) refreshFunc(ctx context.Context) func() {
 
 // fullRefresh performs full refresh for an unused storage pool and makes it active.
 func (r *Retrieval) fullRefresh(ctx context.Context) error {
+	if r.State.Status == models.Refreshing {
+		alert := telemetry.Alert{
+			Level:   models.RefreshSkipped,
+			Message: "The data refresh is currently in progress. Skip a new data refresh iteration",
+		}
+		r.State.addAlert(alert)
+		r.tm.SendEvent(ctx, telemetry.AlertEvent, alert)
+		log.Msg(alert.Message)
+
+		return nil
+	}
+
 	// Stop previous runs and snapshot schedulers.
 	if r.ctxCancel != nil {
 		r.ctxCancel()