[validate] run IDENTIFY_SYSTEM on replication conn (#2373)

Co-authored-by: Philip Dubé <[email protected]>
PeerDB-io · Dec 18, 2024 · 4bb22cd · 4bb22cd
1 parent 1573393
commit 4bb22cd
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/flow/connectors/postgres/validate.go b/flow/connectors/postgres/validate.go
@@ -139,6 +139,11 @@ func (c *PostgresConnector) CheckReplicationConnectivity(ctx context.Context) er
 	if err != nil {
 		return fmt.Errorf("failed to create replication connection: %v", err)
 	}
+	defer conn.Close(ctx)
+
+	if _, err := conn.Exec(ctx, "IDENTIFY_SYSTEM"); err != nil {
+		return fmt.Errorf("failed to execute IDENTIFY_SYSTEM on replication connection: %w", err)
+	}
 
 	return conn.Close(ctx)
 }

diff --git a/flow/peerdbenv/dynamicconf.go b/flow/peerdbenv/dynamicconf.go
@@ -33,7 +33,7 @@ var DynamicSettings = [...]*protos.DynamicSetting{
 			"use with PEERDB_PARALLEL_SYNC_NORMALIZE",
 		DefaultValue:     "0",
 		ValueType:        protos.DynconfValueType_INT,
-		ApplyMode:        protos.DynconfApplyMode_APPLY_MODE_IMMEDIATE,
+		ApplyMode:        protos.DynconfApplyMode_APPLY_MODE_AFTER_RESUME,
 		TargetForSetting: protos.DynconfTarget_ALL,
 	},
 	{