use with force

Amogh-Bharadwaj · Amogh-Bharadwaj · commit 4529a840d719 · 2026-05-07T14:05:58.000+05:30
diff --git a/flow/e2e/pg_schema_dump_test.go b/flow/e2e/pg_schema_dump_test.go
@@ -31,9 +31,7 @@ func (s PeerFlowE2ETestSuitePG) Test_PG_Schema_Dump_And_CDC() {
 			return
 		}
 		defer dropConn.Close(ctx)
-		_, _ = dropConn.Exec(ctx, fmt.Sprintf(
-			"SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname='%s' AND pid <> pg_backend_pid()", dstDBName))
-		if _, err := dropConn.Exec(ctx, "DROP DATABASE IF EXISTS "+dstDBName); err != nil {
+		if _, err := dropConn.Exec(ctx, "DROP DATABASE IF EXISTS "+dstDBName+" WITH (FORCE)"); err != nil {
 			s.t.Logf("failed to drop destination database %s: %v", dstDBName, err)
 		}
 	})

Original file line number	Diff line number	Diff line change
`@@ -31,9 +31,7 @@ func (s PeerFlowE2ETestSuitePG) Test_PG_Schema_Dump_And_CDC() {`
`31`	`31`	`return`
`32`	`32`	`}`
`33`	`33`	`defer dropConn.Close(ctx)`
`34`		`- _, _ = dropConn.Exec(ctx, fmt.Sprintf(`
`35`		`- "SELECT pg_terminate_backend(pid) FROM pg_stat_activity WHERE datname='%s' AND pid <> pg_backend_pid()", dstDBName))`
`36`		`- if _, err := dropConn.Exec(ctx, "DROP DATABASE IF EXISTS "+dstDBName); err != nil {`
	`34`	`+ if _, err := dropConn.Exec(ctx, "DROP DATABASE IF EXISTS "+dstDBName+" WITH (FORCE)"); err != nil {`
`37`	`35`	`s.t.Logf("failed to drop destination database %s: %v", dstDBName, err)`
`38`	`36`	`}`
`39`	`37`	`})`