it works???

PeerDB-io · Feb 8, 2024 · 2cbc17b · 2cbc17b
1 parent 30bac25
commit 2cbc17b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 2 deletions.
diff --git 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
@@ -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()