Merge pull request #201 from formancehq/feat/ledgeupgrade

feat: use a migration job for ledger 2.2 too...
formancehq · Dec 20, 2024 · 5ca2214 · 5ca2214
2 parents 3dc1dd8 + 14dd0bd
commit 5ca2214
Show file tree

Hide file tree

Showing 2 changed files with 1 addition and 6 deletions.
diff --git a/internal/resources/ledgers/deployments.go b/internal/resources/ledgers/deployments.go
@@ -149,7 +149,6 @@ func installLedgerStateless(ctx core.Context, stack *v1beta1.Stack,
 	}
 	container.Env = append(container.Env,
 		core.Env("BIND", ":8080"),
-		core.Env("AUTO_UPGRADE", "true"),
 	)
 
 	experimentalFeatures, err := settings.GetBoolOrFalse(ctx, stack.Name, "ledger", "experimental-features")

diff --git a/internal/resources/ledgers/init.go b/internal/resources/ledgers/init.go
@@ -56,13 +56,9 @@ func Reconcile(ctx Context, stack *v1beta1.Stack, ledger *v1beta1.Ledger, versio
 	}
 
 	isV2 := false
-	isV2_2 := false
 	if !semver.IsValid(version) || semver.Compare(version, "v2.0.0-alpha") > 0 {
 		isV2 = true
 	}
-	if !semver.IsValid(version) || semver.Compare(version, "v2.2.0-alpha") > 0 {
-		isV2_2 = true
-	}
 
 	if err := benthosstreams.LoadFromFileSystem(ctx, benthos.Streams, ledger, "streams/ledger", "ingestion"); err != nil {
 		return err
@@ -96,7 +92,7 @@ func Reconcile(ctx Context, stack *v1beta1.Stack, ledger *v1beta1.Ledger, versio
 		return NewPendingError().WithMessage("database not ready")
 	}
 
-	if isV2 && !isV2_2 && databases.GetSavedModuleVersion(database) != version {
+	if isV2 && databases.GetSavedModuleVersion(database) != version {
 		if err := migrate(ctx, stack, ledger, database, image, version); err != nil {
 			return err
 		}