Fixing target base scale instance concurrency for queues

Azure · Jan 10, 2024 · d89d719 · d89d719
1 parent 8a70af0
commit d89d719
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.../Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueTargetScaler.cs b/.../Microsoft.Azure.WebJobs.Extensions.Storage.Common/src/Shared/Queues/QueueTargetScaler.cs
@@ -55,7 +55,7 @@ public async Task<TargetScalerResult> GetScaleResultAsync(TargetScalerContext co
 
         internal TargetScalerResult GetScaleResultInternal(TargetScalerContext context, int queueLength)
         {
-            int concurrency = !context.InstanceConcurrency.HasValue ? _options.BatchSize : context.InstanceConcurrency.Value;
+            int concurrency = !context.InstanceConcurrency.HasValue ? _options.BatchSize + _options.NewBatchThreshold : context.InstanceConcurrency.Value;
 
             if (concurrency < 0)
             {

diff --git a/...storage/Microsoft.Azure.WebJobs.Extensions.Storage.Queues/tests/QueueTargetScalerTests.cs b/...storage/Microsoft.Azure.WebJobs.Extensions.Storage.Queues/tests/QueueTargetScalerTests.cs
@@ -32,7 +32,7 @@ public void Setup()
         [TestCase(160, 20, 8)]
         public void QueueTargetScaler_Returns_Expected(int queueLength, int? concurrency, int expectedTargetWorkerCount)
         {
-            QueuesOptions options = new QueuesOptions { BatchSize = 16 };
+            QueuesOptions options = new QueuesOptions { BatchSize = 8, NewBatchThreshold = 8 };
 
             TargetScalerContext context = new TargetScalerContext
             {