From da0555fb188a5db1e85e67f951aeca57f2142572 Mon Sep 17 00:00:00 2001 From: "Giau. Tran Minh" Date: Thu, 25 Apr 2024 17:53:39 +0700 Subject: [PATCH] chore: patch logic --- controllers/atlasmigration_controller.go | 7 ++----- 1 file changed, 2 insertions(+), 5 deletions(-) diff --git a/controllers/atlasmigration_controller.go b/controllers/atlasmigration_controller.go index feed578f..c7e268c1 100644 --- a/controllers/atlasmigration_controller.go +++ b/controllers/atlasmigration_controller.go @@ -313,10 +313,6 @@ func (r *AtlasMigrationReconciler) reconcile(ctx context.Context, wd *atlas.Work case len(status.Pending) == 0 && len(status.Applied) > 0 && len(status.Available) < len(status.Applied): // Migration is downgraded log.Info("downgrading migration detected", "migrateDown", migrateDown) - if migrateDown && (data.Cloud == nil || data.Cloud.RemoteDir == nil) { - migrateDown = false - log.Info("downgrade only supported with cloud directory", "migrateDown", migrateDown) - } if migrateDown { // The downgrade is allowed, apply the last migration version last := status.Available[len(status.Available)-1] @@ -364,7 +360,7 @@ func (r *AtlasMigrationReconciler) reconcile(ctx context.Context, wd *atlas.Work case StateApplied, StateApproved: return &dbv1alpha1.AtlasMigrationStatus{ LastApplied: run.Start.Unix(), - LastAppliedVersion: run.Current, + LastAppliedVersion: run.Target, }, nil } } @@ -416,6 +412,7 @@ func (r *AtlasMigrationReconciler) extractData(ctx context.Context, res *dbv1alp RevisionsSchema: s.RevisionsSchema, Baseline: s.Baseline, ExecOrder: string(s.ExecOrder), + MigrateDown: s.AllowedMigrateDown, } ) if env := s.EnvName; env != "" {