From 2cbc17b3fc3a789ecfe2cc3e3930f49a54d1c2f4 Mon Sep 17 00:00:00 2001 From: Kevin Biju Date: Thu, 8 Feb 2024 15:46:14 +0530 Subject: [PATCH] it works??? --- .github/workflows/flow.yml | 4 ++-- flow/e2e/postgres/peer_flow_pg_test.go | 1 + 2 files changed, 3 insertions(+), 2 deletions(-) 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()