From 20a644cb9f3b64cfc3d9a3d5adc5bb517fa06fca Mon Sep 17 00:00:00 2001 From: Kaushik Iska Date: Fri, 10 Nov 2023 15:22:00 -0500 Subject: [PATCH] remove some printlns --- flow/e2e/bigquery/peer_flow_bq_test.go | 2 -- flow/e2e/snowflake/peer_flow_sf_test.go | 3 --- flow/e2e/test_utils.go | 1 - 3 files changed, 6 deletions(-) diff --git a/flow/e2e/bigquery/peer_flow_bq_test.go b/flow/e2e/bigquery/peer_flow_bq_test.go index d9111932a1..fe8bee3d6b 100644 --- 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 index 7bccc6cfa8..163d61447e 100644 --- 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 index dfa06a44c2..f26afc2ee1 100644 --- 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 {