investigating why rows aren't same, probably some thread safety issue

Author: serprex

.github/workflows/flow.yml

@@ -93,7 +93,7 @@ jobs:
 
       - name: run tests
         run: |
-          gotestsum --format testname -- -p 4 ./... -timeout 2400s
+          gotestsum --format testname -- -p 4 ./e2e/snowflake/... -timeout 2400s
         working-directory: ./flow
         env:
           AWS_ACCESS_KEY_ID: ${{ secrets.AWS_ACCESS_KEY_ID }}

flow/e2e/snowflake/peer_flow_sf_test.go

@@ -388,7 +388,7 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Toast_SF(t *testing.T) {
 			Executing a transaction which
 			1. changes both toast column
 			2. changes no toast column
-			2. changes 1 toast column
+			3. changes 1 toast column
 		*/
 		_, err = s.pool.Exec(context.Background(), fmt.Sprintf(`
 			BEGIN;

flow/e2e/snowflake/qrep_flow_sf_test.go

@@ -54,6 +54,8 @@ func (s *PeerFlowE2ETestSuiteSF) compareTableContentsSF(t *testing.T, tableName
 	sfRows, err := s.sfHelper.ExecuteAndProcessQuery(sfSelQuery)
 	require.NoError(t, err)
 
+	t.Logf("compare %v = %v", pgRows, sfRows)
+
 	assert.True(t, pgRows.Equals(sfRows), "rows from source and destination tables are not equal")
 }
 
@@ -243,7 +245,7 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Complete_QRep_Flow_Avro_SF_S3_Integration(
 	query := fmt.Sprintf("SELECT * FROM e2e_test_%s.%s WHERE updated_at BETWEEN {{.start}} AND {{.end}}",
 		snowflakeSuffix, tblName)
 
-	sfPeer := s.sfHelper.Peer
+	sfPeer := s.sfHelper.Peer // TODO clone
 	sfPeer.GetSnowflakeConfig().S3Integration = "peerdb_s3_integration"
 
 	qrepConfig, err := e2e.CreateQRepWorkflowConfig(