diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go
index 25e1c62cd1..e949a4c084 100644
--- a/flow/e2e/postgres/peer_flow_pg_test.go
+++ b/flow/e2e/postgres/peer_flow_pg_test.go
@@ -95,7 +95,6 @@ func (s PeerFlowE2ETestSuitePG) Test_Simple_Flow_PG() {
 	err = env.GetWorkflowError()
 
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 
 	err = s.comparePGTables(srcTableName, dstTableName, "id,key,value")
@@ -259,7 +258,6 @@ func (s PeerFlowE2ETestSuitePG) Test_Simple_Schema_Changes_PG() {
 	err = env.GetWorkflowError()
 
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 
 	env.AssertExpectations(s.t)
@@ -331,7 +329,6 @@ func (s PeerFlowE2ETestSuitePG) Test_Composite_PKey_PG() {
 	err = env.GetWorkflowError()
 
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 
 	err = s.comparePGTables(srcTableName, dstTableName, "id,c1,c2,t")
@@ -411,7 +408,6 @@ func (s PeerFlowE2ETestSuitePG) Test_Composite_PKey_Toast_1_PG() {
 	err = env.GetWorkflowError()
 
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 
 	// verify our updates and delete happened
@@ -488,7 +484,6 @@ func (s PeerFlowE2ETestSuitePG) Test_Composite_PKey_Toast_2_PG() {
 	err = env.GetWorkflowError()
 
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 
 	// verify our updates and delete happened
@@ -555,7 +550,6 @@ func (s PeerFlowE2ETestSuitePG) Test_PeerDB_Columns() {
 
 	err = env.GetWorkflowError()
 	// allow only continue as new error
-	s.Error(err)
 	require.Contains(s.t, err.Error(), "continue as new")
 	checkErr := s.checkPeerdbColumns(dstTableName, 1)
 	require.NoError(s.t, checkErr)