log

PeerDB-io · Mar 6, 2024 · 1ea7f60 · 1ea7f60
1 parent 4f0a361
commit 1ea7f60
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 10 deletions.
diff --git a/flow/e2e/congen.go b/flow/e2e/congen.go
@@ -173,17 +173,14 @@ func TableMappings(s GenericSuite, tables ...string) []*protos.TableMapping {
 	if len(tables)&1 != 0 {
 		panic("must receive even number of table names")
 	}
-	tableMappings := make([]*protos.TableMapping, len(tables)/2)
+	tm := make([]*protos.TableMapping, len(tables)/2)
 	for i := 0; i < len(tables); i += 2 {
-		tableMappings = append(
-			tableMappings,
-			&protos.TableMapping{
-				SourceTableIdentifier:      AttachSchema(s, tables[i]),
-				DestinationTableIdentifier: s.DestinationTable(tables[i+1]),
-			},
-		)
-	}
-	return tableMappings
+		tm = append(tm, &protos.TableMapping{
+			SourceTableIdentifier:      AttachSchema(s, tables[i]),
+			DestinationTableIdentifier: s.DestinationTable(tables[i+1]),
+		})
+	}
+	return tm
 }
 
 func (c *FlowConnectionGenerationConfig) GenerateFlowConnectionConfigs() *protos.FlowConnectionConfigs {

diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go
@@ -98,6 +98,10 @@ func (s PeerFlowE2ETestSuitePG) Test_Simple_Flow_PG() {
 	}
 
 	flowConnConfig := connectionGen.GenerateFlowConnectionConfigs()
+	for _, tm := range flowConnConfig.TableMappings {
+		s.t.Log(tm.SourceTableIdentifier, tm.DestinationTableIdentifier)
+		s.t.Log(s.attachSchemaSuffix("test_simple_flow"), s.attachSchemaSuffix("test_simple_flow_dst"))
+	}
 	flowConnConfig.MaxBatchSize = 100
 
 	tc := e2e.NewTemporalClient(s.t)