diff --git a/flow/e2e/snowflake/peer_flow_sf_test.go b/flow/e2e/snowflake/peer_flow_sf_test.go index 4279461de9..3bd801a02f 100644 --- a/flow/e2e/snowflake/peer_flow_sf_test.go +++ b/flow/e2e/snowflake/peer_flow_sf_test.go @@ -1407,7 +1407,7 @@ func (s *PeerFlowE2ETestSuiteSF) Test_Column_Exclusion(t *testing.T) { require.NoError(t, err) }() - env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, &config, &limits, nil) + env.ExecuteWorkflow(peerflow.CDCFlowWorkflowWithConfig, config, &limits, nil) require.True(t, env.IsWorkflowCompleted()) err = env.GetWorkflowError() s.Error(err)