diff --git a/.github/workflows/flow.yml b/.github/workflows/flow.yml
index 59e1128117..c672da5340 100644
--- a/.github/workflows/flow.yml
+++ b/.github/workflows/flow.yml
@@ -103,8 +103,8 @@ jobs:
 
       - name: run tests
         run: |
-          gotestsum --format testname -- -p 1 -parallel 1 ./... -timeout 1200s
-        working-directory: ./flow/e2e/postgres
+          gotestsum --format testname -- -p 24 ./... -timeout 1200s
+        working-directory: ./flow
         env:
           AWS_ACCESS_KEY_ID: ${{ secrets.AWS_ACCESS_KEY_ID }}
           AWS_SECRET_ACCESS_KEY: ${{ secrets.AWS_SECRET_ACCESS_KEY }}
diff --git a/flow/e2e/postgres/peer_flow_pg_test.go b/flow/e2e/postgres/peer_flow_pg_test.go
index 08cb7f8c39..36aaa089cf 100644
--- a/flow/e2e/postgres/peer_flow_pg_test.go
+++ b/flow/e2e/postgres/peer_flow_pg_test.go
@@ -1195,6 +1195,7 @@ func (s PeerFlowE2ETestSuitePG) Test_Dynamic_Mirror_Config_Via_Signals() {
 		s.t.Log("Sent pause signal")
 		sentPause = true
 	}, 28*time.Second)
+	// this signal being sent also unblocks another WaitFor
 	env.RegisterDelayedCallback(func() {
 		e2e.EnvWaitFor(s.t, env, 1*time.Minute, "send update signal after pause confirmed", func() bool {
 			flowStatus := getFlowStatus()