drop mirror: ignore `cannot execute DROP PUBLICATION in a read-only t…

…ransaction (SQLSTATE 25006)` (#2381) still report this as an error during validation Co-authored-by: Kevin Biju <[email protected]>
PeerDB-io · Dec 20, 2024 · 863e237 · 863e237
1 parent b87d0a3
commit 863e237
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/flow/connectors/postgres/postgres.go b/flow/connectors/postgres/postgres.go
@@ -1149,7 +1149,9 @@ func (c *PostgresConnector) PullFlowCleanup(ctx context.Context, jobName string)
 	}
 
 	if publicationExists {
-		if _, err := c.conn.Exec(ctx, "DROP PUBLICATION IF EXISTS "+publicationName); err != nil {
+		if _, err := c.conn.Exec(
+			ctx, "DROP PUBLICATION IF EXISTS "+publicationName,
+		); err != nil && !shared.IsSQLStateError(err, pgerrcode.ReadOnlySQLTransaction) {
 			return fmt.Errorf("error dropping publication: %w", err)
 		}
 	}