diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go
index 12c0dda671..be8377f522 100644
--- a/flow/e2e/snowflake/peer_flow_sf_test.go
+++ b/flow/e2e/snowflake/peer_flow_sf_test.go
@@ -427,8 +427,7 @@ func (s PeerFlowE2ETestSuiteSF) Test_Types_SF() {
 	`, srcTableName))
 	e2e.EnvNoError(s.t, env, err)
 
-	e2e.EnvWaitFor(s.t, env, 10*time.Minute, "normalize types", func() bool {
-		s.t.Log("Checking for nulls in all types")
+	e2e.EnvWaitFor(s.t, env, 3*time.Minute, "normalize types", func() bool {
 		noNulls, err := s.sfHelper.CheckNull("test_types_sf", []string{
 			"c41", "c1", "c2", "c3", "c4",
 			"c6", "c39", "c40", "id", "c9", "c11", "c12", "c13", "c14", "c15", "c16", "c17", "c18",
@@ -437,28 +436,22 @@ func (s PeerFlowE2ETestSuiteSF) Test_Types_SF() {
 			"c50", "c51", "c52", "c53", "c54",
 		})
 		if err != nil {
-			s.t.Log(err)
 			return false
 		}
 
-		s.t.Log("Checking for intervals in all types")
 		// interval checks
 		if err := s.checkJSONValue(dstTableName, "c16", "years", "5"); err != nil {
-			s.t.Log(err)
 			return false
 		}
 
 		if err := s.checkJSONValue(dstTableName, "c16", "months", "2"); err != nil {
-			s.t.Log(err)
 			return false
 		}
 
 		if err := s.checkJSONValue(dstTableName, "c16", "days", "29"); err != nil {
-			s.t.Log(err)
 			return false
 		}
 
-		s.t.Log("Checking for json in all types")
 		// check if JSON on snowflake side is a good JSON
 		if err := s.checkJSONValue(dstTableName, "c17", "sai", "1"); err != nil {
 			return false