fix up expected schema

PeerDB-io · Jan 5, 2024 · 9ab0db8 · 9ab0db8
1 parent f937b32
commit 9ab0db8
Showing 1 changed file with 6 additions and 12 deletions.
diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go
@@ -911,16 +911,14 @@ func (s PeerFlowE2ETestSuiteSF) Test_Simple_Schema_Changes_SF() {
 			ColumnNames: []string{
 				"ID",
 				"C1",
-				"C2",
-				"_PEERDB_IS_DELETED",
 				"_PEERDB_SYNCED_AT",
+				"C2",
 			},
 			ColumnTypes: []string{
 				string(qvalue.QValueKindNumeric),
 				string(qvalue.QValueKindNumeric),
-				string(qvalue.QValueKindNumeric),
-				string(qvalue.QValueKindBoolean),
 				string(qvalue.QValueKindTimestamp),
+				string(qvalue.QValueKindNumeric),
 			},
 		}
 		output, err = s.connector.GetTableSchema(&protos.GetTableSchemaBatchInput{
@@ -947,18 +945,16 @@ func (s PeerFlowE2ETestSuiteSF) Test_Simple_Schema_Changes_SF() {
 			ColumnNames: []string{
 				"ID",
 				"C1",
+				"_PEERDB_SYNCED_AT",
 				"C2",
 				"C3",
-				"_PEERDB_IS_DELETED",
-				"_PEERDB_SYNCED_AT",
 			},
 			ColumnTypes: []string{
 				string(qvalue.QValueKindNumeric),
 				string(qvalue.QValueKindNumeric),
+				string(qvalue.QValueKindTimestamp),
 				string(qvalue.QValueKindNumeric),
 				string(qvalue.QValueKindNumeric),
-				string(qvalue.QValueKindBoolean),
-				string(qvalue.QValueKindTimestamp),
 			},
 		}
 		output, err = s.connector.GetTableSchema(&protos.GetTableSchemaBatchInput{
@@ -985,18 +981,16 @@ func (s PeerFlowE2ETestSuiteSF) Test_Simple_Schema_Changes_SF() {
 			ColumnNames: []string{
 				"ID",
 				"C1",
+				"_PEERDB_SYNCED_AT",
 				"C2",
 				"C3",
-				"_PEERDB_IS_DELETED",
-				"_PEERDB_SYNCED_AT",
 			},
 			ColumnTypes: []string{
 				string(qvalue.QValueKindNumeric),
 				string(qvalue.QValueKindNumeric),
+				string(qvalue.QValueKindTimestamp),
 				string(qvalue.QValueKindNumeric),
 				string(qvalue.QValueKindNumeric),
-				string(qvalue.QValueKindBoolean),
-				string(qvalue.QValueKindTimestamp),
 			},
 		}
 		output, err = s.connector.GetTableSchema(&protos.GetTableSchemaBatchInput{