Pteudo 1658 (#361)

infobloxopen · Nov 18, 2024 · f0b26bb · f0b26bb
1 parent 4e01456
commit f0b26bb
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git a/internal/controller/databasecontroller_migrate_test.go b/internal/controller/databasecontroller_migrate_test.go
@@ -308,11 +308,11 @@ var _ = Describe("claim migrate", func() {
 			Expect(activeDB.ConnectionInfo).NotTo(BeNil())
 			Expect(activeDB.ConnectionInfo.Uri()).To(Equal(compareDSN))
 
-			By(fmt.Sprintf("Verify owner of migrated DB is %s", migratedowner))
+			By(fmt.Sprintf("Verify owner of migrated DB is %s", migratedowner+"_a"))
 			row := fakeCli.QueryRowContext(ctxLogger, "select tableowner from pg_tables where tablename = 'users' AND schemaname = 'public';")
 			var owner string
 			Expect(row.Scan(&owner)).NotTo(HaveOccurred())
-			Expect(owner).To(Equal(migratedowner))
+			Expect(owner).To(Equal(migratedowner + "_a"))
 
 		})
 

diff --git a/internal/metrics/databaseclaim.go b/internal/metrics/databaseclaim.go
@@ -41,6 +41,7 @@ func updateMetrics(ctx context.Context, log logr.Logger, client client.Client) {
 	metrics.ErrorStateClaims.Reset()
 	metrics.MigrationStateClaims.Reset()
 	metrics.ActiveDBState.Reset()
+	metrics.ExistingSourceClaims.Reset()
 
 	for _, dbClaim := range databaseClaims.Items {
 		metrics.TotalDatabaseClaims.WithLabelValues(dbClaim.Namespace).Inc()