diff --git a/flow/e2e/postgres/qrep_flow_pg_test.go b/flow/e2e/postgres/qrep_flow_pg_test.go
index 73806816f7..3b497dda63 100644
--- a/flow/e2e/postgres/qrep_flow_pg_test.go
+++ b/flow/e2e/postgres/qrep_flow_pg_test.go
@@ -363,7 +363,7 @@ func (s PeerFlowE2ETestSuitePG) Test_Pause() {
 			s.t.Log(err)
 			return false
 		}
-		var state peerflow.CDCFlowWorkflowState
+		var state *peerflow.CDCFlowWorkflowState
 		err = response.Get(&state)
 		if err != nil {
 			s.t.Fatal("decode failed", err)
@@ -377,7 +377,7 @@ func (s PeerFlowE2ETestSuitePG) Test_Pause() {
 			s.t.Log(err)
 			return false
 		}
-		var state peerflow.CDCFlowWorkflowState
+		var state *peerflow.CDCFlowWorkflowState
 		err = response.Get(&state)
 		if err != nil {
 			s.t.Fatal("decode failed", err)