Skip to content

Commit

Permalink
remove logs
Browse files Browse the repository at this point in the history
  • Loading branch information
Amogh-Bharadwaj committed Mar 21, 2024
1 parent f15ed78 commit fcba214
Showing 1 changed file with 1 addition and 8 deletions.
9 changes: 1 addition & 8 deletions flow/e2e/snowflake/peer_flow_sf_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -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",
Expand All @@ -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
Expand Down

0 comments on commit fcba214

Please sign in to comment.