diff --git a/cmd/api/src/migrations/graph.go b/cmd/api/src/migrations/graph.go index 0eddd0e8e6..722548510f 100644 --- a/cmd/api/src/migrations/graph.go +++ b/cmd/api/src/migrations/graph.go @@ -155,6 +155,10 @@ func (s *GraphMigrator) executeMigrations(ctx context.Context, originalVersion v } } + if releaseVersion := version.GetVersion(); releaseVersion.GreaterThan(mostRecentVersion) { + mostRecentVersion = releaseVersion + } + if mostRecentVersion.GreaterThan(originalVersion) { return UpdateMigrationData(ctx, s.db, mostRecentVersion) } diff --git a/cmd/api/src/migrations/manifest.go b/cmd/api/src/migrations/manifest.go index 98e3df5075..41227c632c 100644 --- a/cmd/api/src/migrations/manifest.go +++ b/cmd/api/src/migrations/manifest.go @@ -43,7 +43,7 @@ func RequiresMigration(ctx context.Context, db graph.Database) (bool, error) { return false, fmt.Errorf("unable to get graph db migration data: %w", err) } } else { - return LatestGraphMigrationVersion().GreaterThan(currentMigration), nil + return version.GetVersion().GreaterThan(currentMigration), nil } } diff --git a/packages/go/dawgs/drivers/pg/pg.go b/packages/go/dawgs/drivers/pg/pg.go index 6e22ad64c9..4ed9d3ad36 100644 --- a/packages/go/dawgs/drivers/pg/pg.go +++ b/packages/go/dawgs/drivers/pg/pg.go @@ -107,8 +107,6 @@ func init() { return nil, fmt.Errorf("expected string for configuration type but got %T", cfg) } else if graphDB, err := newDatabase(connectionString); err != nil { return nil, err - } else if err := graphDB.AssertSchema(ctx, graph.Schema{}); err != nil { - return nil, err } else { return graphDB, nil }