From 60850dbe9cd15bb6194faa9be4e94fd7a0b6eaab Mon Sep 17 00:00:00 2001 From: jmaeagle99 <44687433+jmaeagle99@users.noreply.github.com> Date: Fri, 15 May 2026 14:05:10 -0700 Subject: [PATCH] fix(tests): wait for routing config propagation in worker deployment ramp test --- .../Worker/WorkerDeploymentVersioningTests.cs | 13 +++++++++++++ 1 file changed, 13 insertions(+) diff --git a/tests/Temporalio.Tests/Worker/WorkerDeploymentVersioningTests.cs b/tests/Temporalio.Tests/Worker/WorkerDeploymentVersioningTests.cs index eb015521..982db847 100644 --- a/tests/Temporalio.Tests/Worker/WorkerDeploymentVersioningTests.cs +++ b/tests/Temporalio.Tests/Worker/WorkerDeploymentVersioningTests.cs @@ -194,9 +194,15 @@ async Task ExecuteRampTest() // Set current version to v1 and ramp v2 to 100% var conflictToken = (await TestUtils.SetCurrentDeploymentVersionAsync( Client, describeResp.ConflictToken, v1)).ConflictToken; + + await TestUtils.WaitForRoutingConfigPropagationAsync(Client, deploymentName, v1.BuildId); + conflictToken = (await TestUtils.SetRampingVersionAsync( Client, conflictToken, v2, 100)).ConflictToken; + await TestUtils.WaitForRoutingConfigPropagationAsync( + Client, deploymentName, v1.BuildId, v2.BuildId); + // Run workflows and verify they run on v2 for (int i = 0; i < 3; i++) { @@ -210,6 +216,10 @@ async Task ExecuteRampTest() // Set ramp to 0, expecting workflows to run on v1 conflictToken = (await TestUtils.SetRampingVersionAsync(Client, conflictToken, v2, 0)).ConflictToken; + + await TestUtils.WaitForRoutingConfigPropagationAsync( + Client, deploymentName, v1.BuildId, v2.BuildId); + for (int i = 0; i < 3; i++) { var wfa = await Client.StartWorkflowAsync( @@ -223,6 +233,9 @@ async Task ExecuteRampTest() // Set ramp to 50 and eventually verify workflows run on both versions await TestUtils.SetRampingVersionAsync(Client, conflictToken, v2, 50); + await TestUtils.WaitForRoutingConfigPropagationAsync( + Client, deploymentName, v1.BuildId, v2.BuildId); + var seenResults = new HashSet(); async Task RunAndRecord()