test: different config for MultiThread config test

camunda-community-hub · Sep 25, 2024 · f18b406 · f18b406
1 parent 8f87364
commit f18b406
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 5 deletions.
diff --git a/test/Zeebe.Client.Accelerator.Integration.Tests/Handlers/MultiThreadJobHandler.cs b/test/Zeebe.Client.Accelerator.Integration.Tests/Handlers/MultiThreadJobHandler.cs
@@ -7,8 +7,8 @@
 
 namespace Zeebe.Client.Accelerator.Integration.Tests.Handlers
 {
-    [MaxJobsActive(60)]
-    [HandlerThreads(3)]
+    [MaxJobsActive(120)]
+    [HandlerThreads(8)]
     public class MultiThreadJobHandler : IAsyncZeebeWorkerWithResult<Output>
     {
 

diff --git a/test/Zeebe.Client.Accelerator.Integration.Tests/Test.cs b/test/Zeebe.Client.Accelerator.Integration.Tests/Test.cs
@@ -143,7 +143,7 @@ public async Task UsesMultipleThreadsWhenConfigured()
             Assert.True(deployResponse.Key > 0);
 
             var input = new List<int>();
-            for (int i = 0; i < 60; i++) input.Add(i);
+            for (int i = 0; i < 120; i++) input.Add(i);
 
             var correlationId = Guid.NewGuid();
             await zeebeClient.NewCreateProcessInstanceCommand()
@@ -155,10 +155,11 @@ await zeebeClient.NewCreateProcessInstanceCommand()
                     CorrelationId = correlationId
                 })
                 .Send();
-            WaitForHandlersToComplete(60, 6000);
+            WaitForHandlersToComplete(120, 10000);
 
             var variables = zeebeClient.ReceiveMessage<MultiThreadVariables>("responseFor_" + correlationId, TimeSpan.FromSeconds(25));
-            Assert.True(variables.UsedThreads.Distinct().Count() >= 3); // not exact due to the underlying TPL implementation internals
+            _testOutputHelper.WriteLine("NumThreads: " + variables.UsedThreads.Distinct().Count());
+            Assert.True(variables.UsedThreads.Distinct().Count() >= 8); // not exact due to the underlying TPL implementation internals
 
         }