Add test

Author: Sushisource

src/WorkerVersioning/Program.cs

@@ -49,7 +49,7 @@ public static async Task Main(string[] args)
         }
     }
 
-    private static async Task RunDemoAsync(TemporalClient client)
+    public static async Task RunDemoAsync(TemporalClient client)
     {
         // Wait for v1 worker and set as current version
         var workerV1Version = new WorkerDeploymentVersion(Program.DeploymentName, "1.0");

tests/TemporalioSamples.Tests.csproj

@@ -31,6 +31,7 @@
     <ProjectReference Include="..\src\UpdateWithStartLazyInit\TemporalioSamples.UpdateWithStartLazyInit.csproj" />
     <ProjectReference Include="..\src\WorkerSpecificTaskQueues\TemporalioSamples.WorkerSpecificTaskQueues.csproj" />
     <ProjectReference Include="..\src\WorkflowUpdate\TemporalioSamples.WorkflowUpdate.csproj" />
+    <ProjectReference Include="..\src\WorkerVersioning\TemporalioSamples.WorkerVersioning.csproj" />
     <ProjectReference Include="..\src\SleepForDays\TemporalioSamples.SleepForDays.csproj" />
   </ItemGroup>
 

tests/WorkerVersioning/WorkerVersioningTests.cs

@@ -0,0 +1,44 @@
+namespace TemporalioSamples.Tests.WorkerVersioning;
+
+using Temporalio.Client;
+using TemporalioSamples.WorkerVersioning;
+using Xunit;
+using Xunit.Abstractions;
+
+public class WorkerVersioningTests : WorkflowEnvironmentTestBase
+{
+    public WorkerVersioningTests(ITestOutputHelper output, WorkflowEnvironment env)
+        : base(output, env)
+    {
+    }
+
+    [Fact]
+    public async Task WorkerVersioningSampleCanRun()
+    {
+        var temporalClient = new TemporalClient(Client.Connection, Client.Options);
+
+        using var cts = new CancellationTokenSource();
+
+        var workerV1Task = Task.Run(() => WorkerV1.RunAsync(Client, cts.Token));
+        var workerV1_1Task = Task.Run(() => WorkerV1Dot1.RunAsync(Client, cts.Token));
+        var workerV2Task = Task.Run(() => WorkerV2.RunAsync(Client, cts.Token));
+
+        try
+        {
+            await Program.RunDemoAsync(temporalClient);
+            Assert.True(true, "Worker versioning demo completed successfully");
+        }
+        finally
+        {
+            await cts.CancelAsync();
+
+            try
+            {
+                await Task.WhenAll(workerV1Task, workerV1_1Task, workerV2Task);
+            }
+            catch (OperationCanceledException)
+            {
+            }
+        }
+    }
+}