print comparison error

flow/e2e/postgres/peer_flow_pg_test.go

@@ -1270,7 +1270,9 @@ func (s PeerFlowE2ETestSuitePG) Test_Dynamic_Mirror_Config_Via_Signals() {
 			return s.comparePGTables(srcTable1Name, dstTable1Name, "id,t") == nil
 		})
 		e2e.EnvWaitFor(s.t, env, 2*time.Minute, "initial load + normalize 18 records - second table", func() bool {
-			return s.comparePGTables(srcTable2Name, dstTable2Name, "id,t") == nil
+			err := s.comparePGTables(srcTable2Name, dstTable2Name, "id,t")
+			s.t.Log("TEST", err)
+			return err == nil
 		})
 
 		workflowState = getWorkflowState()

flow/e2e/postgres/qrep_flow_pg_test.go

@@ -12,6 +12,7 @@ import (
 	"github.com/jackc/pgx/v5/pgtype"
 	"github.com/joho/godotenv"
 	"github.com/stretchr/testify/require"
+	"golang.org/x/sync/errgroup"
 
 	connpostgres "github.com/PeerDB-io/peer-flow/connectors/postgres"
 	"github.com/PeerDB-io/peer-flow/e2e"
@@ -83,16 +84,16 @@ func (s PeerFlowE2ETestSuitePG) setupSourceTable(tableName string, rowCount int)
 }
 
 func (s PeerFlowE2ETestSuitePG) comparePGTables(srcSchemaQualified, dstSchemaQualified, selector string) error {
-	// Execute the two EXCEPT queries
-	if err := s.compareQuery(srcSchemaQualified, dstSchemaQualified, selector); err != nil {
-		return err
-	}
-	if err := s.compareQuery(dstSchemaQualified, srcSchemaQualified, selector); err != nil {
-		return err
-	}
-
-	// If no error is returned, then the contents of the two tables are the same
-	return nil
+	ctx, cancel := context.WithTimeout(context.Background(), time.Minute)
+	defer cancel()
+	group, _ := errgroup.WithContext(ctx)
+	group.Go(func() error {
+		return s.compareQuery(srcSchemaQualified, dstSchemaQualified, selector)
+	})
+	group.Go(func() error {
+		return s.compareQuery(dstSchemaQualified, srcSchemaQualified, selector)
+	})
+	return group.Wait()
 }
 
 func (s PeerFlowE2ETestSuitePG) checkEnums(srcSchemaQualified, dstSchemaQualified string) error {