diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go index bb0729aabe..fc7e134784 100644 --- a/flow/e2e/snowflake/peer_flow_sf_test.go +++ b/flow/e2e/snowflake/peer_flow_sf_test.go @@ -41,13 +41,13 @@ func TestPeerFlowE2ETestSuiteSF(t *testing.T) { s.FailNow() } - // if s.sfHelper != nil { - // err = s.sfHelper.Cleanup() - // if err != nil { - // slog.Error("failed to tear down Snowflake", slog.Any("error", err)) - // s.FailNow() - // } - // } + if s.sfHelper != nil { + err = s.sfHelper.Cleanup() + if err != nil { + slog.Error("failed to tear down Snowflake", slog.Any("error", err)) + s.FailNow() + } + } err = s.connector.Close() if err != nil {