remove some printlns

PeerDB-io · Nov 10, 2023 · 20a644c · 20a644c
1 parent 1f697a7
commit 20a644c
Show file tree

Hide file tree

Showing 3 changed files with 0 additions and 6 deletions.
diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go
@@ -720,7 +720,6 @@ func (s *PeerFlowE2ETestSuiteBQ) Test_Types_BQ(t *testing.T) {
 		ARRAY['hello','bye'];
 		`, srcTableName))
 		require.NoError(t, err)
-		fmt.Println("Executed an insert with all types")
 	}()
 
 	env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, flowConnConfig, &limits, nil)
@@ -802,7 +801,6 @@ func (s *PeerFlowE2ETestSuiteBQ) Test_Types_Avro_BQ(t *testing.T) {
 		ARRAY['hello','bye'];
 		`, srcTableName))
 		require.NoError(t, err)
-		fmt.Println("Executed an insert with all types")
 	}()
 
 	env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, flowConnConfig, &limits, nil)

diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go
@@ -785,7 +785,6 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Types_SF(t *testing.T) {
 		'POLYGON((-74.0060 40.7128, -73.9352 40.7306, -73.9123 40.7831, -74.0060 40.7128))';
 		`, srcTableName))
 		require.NoError(t, err)
-		fmt.Println("Executed an insert with all types")
 	}()
 
 	env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, flowConnConfig, &limits, nil)
@@ -867,7 +866,6 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Types_SF_Avro_CDC(t *testing.T) {
 		'POLYGON((-74.0060 40.7128, -73.9352 40.7306, -73.9123 40.7831, -74.0060 40.7128))';
 		`, srcTableName))
 		require.NoError(t, err)
-		fmt.Println("Executed an insert with all types")
 	}()
 
 	env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, flowConnConfig, &limits, nil)
@@ -935,7 +933,6 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Multi_Table_SF(t *testing.T) {
 		INSERT INTO %s (c1,c2) VALUES (-1,'dummy_-1');
 		`, srcTable1Name, srcTable2Name))
 		require.NoError(t, err)
-		fmt.Println("Executed an insert with all types")
 	}()
 
 	env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, flowConnConfig, &limits, nil)

diff --git a/flow/e2e/test_utils.go b/flow/e2e/test_utils.go
@@ -72,7 +72,6 @@ func SetupCDCFlowStatusQuery(env *testsuite.TestWorkflowEnvironment,
 			}
 
 			if state.SetupComplete {
-				fmt.Println("query indicates setup is complete")
 				break
 			}
 		} else {
-Original file line number
+Diff line change
@@ Expand Up @@
     			}
     			if state.SetupComplete {
-    				fmt.Println("query indicates setup is complete")
     				break
     			}
     		} else {
@@ Expand Down @@