.Net: Processes UTs causing Build pipeline errors (#11008)

### Description
Fixing intermittent build failure caused by Process Local Unittest that
used shared Counter Step

Fixes #11019

### Contribution Checklist
<!-- Before submitting this PR, please make sure: -->

- [x] The code builds clean without any errors or warnings
- [x] The PR follows the [SK Contribution
Guidelines](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md)
and the [pre-submission formatting
script](https://github.com/microsoft/semantic-kernel/blob/main/CONTRIBUTING.md#development-scripts)
raises no violations
- [x] All unit tests pass, and I have added new tests where possible
- [x] I didn't break anyone 😄

---------

Co-authored-by: Roger Barreto <19890735+RogerBarreto@users.noreply.github.com>
Co-authored-by: Mark Wallace <127216156+markwallace-microsoft@users.noreply.github.com>

Author: 3 people

dotnet/src/Experimental/Process.UnitTests/Runtime.Local/LocalMapTests.cs

@@ -4,6 +4,8 @@
 using System.IO;
 using System.Linq;
 using System.Threading.Tasks;
+using SemanticKernel.Process.TestsShared.Services;
+using SemanticKernel.Process.TestsShared.Setup;
 using SemanticKernel.Process.TestsShared.Steps;
 using Xunit;
 
@@ -311,15 +313,16 @@ public async Task ProcessMapResultWithTargetExtraAsync()
             .SendEventTo(new ProcessFunctionTargetBuilder(unionStep, UnionStep.SumSquareFunction));
 
         KernelProcess processInstance = process.Build();
-        Kernel kernel = new();
+        CounterService counterService = new();
+        Kernel kernel = KernelSetup.SetupKernelWithCounterService(counterService);
 
         // Act
         await using LocalKernelProcessContext processContext = await this.RunProcessAsync(kernel, processInstance, new int[] { 1, 2, 3, 4, 5 }, "Start");
 
         // Assert
         UnionState unionState = await GetUnionStateAsync(processContext);
         Assert.Equal(55L, unionState.SquareResult);
-        Assert.Equal(5, CommonSteps.CountStep.GetCount(CounterName));
+        Assert.Equal(5, counterService.GetCount());
     }
 
     /// <summary>

dotnet/src/Experimental/Process.UnitTests/Runtime.Local/LocalProxyTests.cs

@@ -2,6 +2,8 @@
 using System;
 using System.Threading.Tasks;
 using SemanticKernel.Process.TestsShared.CloudEvents;
+using SemanticKernel.Process.TestsShared.Services;
+using SemanticKernel.Process.TestsShared.Setup;
 using SemanticKernel.Process.TestsShared.Steps;
 using Xunit;
 
@@ -34,7 +36,8 @@ public async Task ProcessWithProxyWithSingleTopicCalledTwiceAsync()
         counterStep.OnFunctionResult().EmitExternalEvent(proxyStep, this._topic1);
 
         KernelProcess processInstance = process.Build();
-        Kernel kernel = new();
+        CounterService counterService = new();
+        Kernel kernel = KernelSetup.SetupKernelWithCounterService(counterService);
 
         // Act
         await using (LocalKernelProcessContext processContext = await this.RunProcessAsync(kernel, processInstance, null, this._startProcessEvent, externalMessageChannel: mockProxyClient))
@@ -95,7 +98,8 @@ public async Task ProcessWithCyclesAndProxyWithTwoTopicsAsync()
         var mockProxyClient = new MockCloudEventClient();
         ProcessBuilder process = this.GetSampleProcessWithProxyEmittingTwoTopics(nameof(ProcessWithCyclesAndProxyWithTwoTopicsAsync), counterName: nameof(ProcessWithCyclesAndProxyWithTwoTopicsAsync));
         KernelProcess processInstance = process.Build();
-        Kernel kernel = new();
+        CounterService counterService = new();
+        Kernel kernel = KernelSetup.SetupKernelWithCounterService(counterService);
 
         // Act
         await using (LocalKernelProcessContext processContext = await this.RunProcessAsync(kernel, processInstance, null, this._startProcessEvent, externalMessageChannel: mockProxyClient))
@@ -138,7 +142,8 @@ public async Task ProcessWithProxyIn2LevelsNestedProcessEmitsTwoTopicsAsync()
             .SendEventTo(innerProcess.WhereInputEventIs(this._startProcessEvent));
 
         KernelProcess processInstance = process.Build();
-        Kernel kernel = new();
+        CounterService counterService = new();
+        Kernel kernel = KernelSetup.SetupKernelWithCounterService(counterService);
 
         // Act
         await using (LocalKernelProcessContext processContext = await this.RunProcessAsync(kernel, processInstance, null, this._startProcessEvent, externalMessageChannel: mockProxyClient))
@@ -187,7 +192,8 @@ public async Task ProcessWithProxyIn4LevelsNestedProcessEmitsTwoTopicsAsync()
             .SendEventTo(innerProcess.WhereInputEventIs(this._startProcessEvent));
 
         KernelProcess processInstance = process.Build();
-        Kernel kernel = new();
+        CounterService counterService = new();
+        Kernel kernel = KernelSetup.SetupKernelWithCounterService(counterService);
 
         // Act
         await using (LocalKernelProcessContext processContext = await this.RunProcessAsync(kernel, processInstance, null, this._startProcessEvent, externalMessageChannel: mockProxyClient))

dotnet/src/InternalUtilities/process/TestsShared/Services/CounterService.cs

@@ -0,0 +1,20 @@
+// Copyright (c) Microsoft. All rights reserved.
+
+using System.Threading;
+
+namespace SemanticKernel.Process.TestsShared.Services;
+
+internal sealed class CounterService : ICounterService
+{
+    internal int _counter = 0;
+    public int GetCount()
+    {
+        return this._counter;
+    }
+
+    public int IncreaseCount()
+    {
+        Interlocked.Increment(ref this._counter);
+        return this._counter;
+    }
+}

dotnet/src/InternalUtilities/process/TestsShared/Services/ICounterService.cs

@@ -0,0 +1,20 @@
+// Copyright (c) Microsoft. All rights reserved.
+namespace SemanticKernel.Process.TestsShared.Services;
+
+/// <summary>
+/// Interface for Counter Service used by <see cref="TestsShared.Steps.CommonSteps.CountStep"/>
+/// </summary>
+public interface ICounterService
+{
+    /// <summary>
+    /// Increase count
+    /// </summary>
+    /// <returns></returns>
+    int IncreaseCount();
+
+    /// <summary>
+    /// Get current count
+    /// </summary>
+    /// <returns></returns>
+    int GetCount();
+}

dotnet/src/InternalUtilities/process/TestsShared/Setup/KernelSetup.cs

@@ -0,0 +1,18 @@
+// Copyright (c) Microsoft. All rights reserved.
+using Microsoft.Extensions.DependencyInjection;
+using Microsoft.SemanticKernel;
+using SemanticKernel.Process.TestsShared.Services;
+
+namespace SemanticKernel.Process.TestsShared.Setup;
+
+internal static class KernelSetup
+{
+    public static Kernel SetupKernelWithCounterService(CounterService counterService)
+    {
+        IKernelBuilder builder = Kernel.CreateBuilder();
+
+        builder.Services.AddSingleton<ICounterService>(counterService);
+
+        return builder.Build();
+    }
+}

dotnet/src/InternalUtilities/process/TestsShared/Steps/CommonSteps.cs

@@ -1,8 +1,8 @@
 // Copyright (c) Microsoft. All rights reserved.
 using System;
-using System.Collections.Generic;
 using System.Threading.Tasks;
 using Microsoft.SemanticKernel;
+using SemanticKernel.Process.TestsShared.Services;
 
 namespace SemanticKernel.Process.TestsShared.Steps;
 
@@ -20,39 +20,18 @@ public sealed class CountStep : KernelProcessStep
     {
         public const string CountFunction = nameof(Count);
 
-        private string _name = null!;
-        private static readonly Dictionary<string, long> s_counters = new();
-
-        public override ValueTask ActivateAsync(KernelProcessStepState state)
+        private readonly ICounterService _counter;
+        public CountStep(ICounterService counterService)
         {
-            this._name = state.Name;
-            return default;
+            this._counter = counterService;
         }
 
         [KernelFunction]
         public string Count()
         {
-            lock (s_counters)
-            {
-                if (s_counters.TryGetValue(this._name, out var counter))
-                {
-                    s_counters[this._name] = counter + 1;
-                }
-                else
-                {
-                    s_counters[this._name] = 1;
-                }
-
-                return s_counters[this._name].ToString();
-            }
-        }
+            int count = this._counter.IncreaseCount();
 
-        public static long GetCount(string name)
-        {
-            lock (s_counters)
-            {
-                return s_counters[name];
-            }
+            return count.ToString();
         }
     }
 
@@ -108,7 +87,4 @@ public string Echo(string message)
             return message;
         }
     }
-
-#pragma warning restore CS1591 // Missing XML comment for publicly visible type or member
-
 }