minor change

nischitpra · nischitpra · commit 1aa9d4aae63a · 2025-08-15T20:51:31.000+05:45
diff --git a/cmd/migrate_valid.go b/cmd/migrate_valid.go
@@ -154,7 +154,7 @@ func NewMigrator() *Migrator {
 	newpublisher := newkafka.GetInstance()
 
 	// psql cursor for new kafka
-	psql, err := storage.NewPostgresConnector(config.Cfg.Storage.Main.Postgres)
+	psql, err := storage.NewPostgresConnector(config.Cfg.Storage.Staging.Postgres)
 	if err != nil {
 		log.Fatal().Err(err).Msg("Failed to initialize psql cursor")
 	}

Original file line number	Diff line number	Diff line change
`@@ -154,7 +154,7 @@ func NewMigrator() *Migrator {`
`154`	`154`	`newpublisher := newkafka.GetInstance()`
`155`	`155`
`156`	`156`	`// psql cursor for new kafka`
`157`		`- psql, err := storage.NewPostgresConnector(config.Cfg.Storage.Main.Postgres)`
	`157`	`+ psql, err := storage.NewPostgresConnector(config.Cfg.Storage.Staging.Postgres)`
`158`	`158`	`if err != nil {`
`159`	`159`	`log.Fatal().Err(err).Msg("Failed to initialize psql cursor")`
`160`	`160`	`}`