Remove unhealthy pump (#12691)

* Up version to 4.2.1 for stress testing pipeline * Remove pump if not at running or not opening states.
Azure · Jul 8, 2020 · 8d84b36 · 8d84b36
1 parent 779c19a
commit 8d84b36
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/sdk/eventhub/Microsoft.Azure.EventHubs.Processor/src/PartitionManager.cs b/sdk/eventhub/Microsoft.Azure.EventHubs.Processor/src/PartitionManager.cs
@@ -521,7 +521,7 @@ async Task CheckAndAddPumpAsync(string partitionId, Lease lease)
             if (this.partitionPumps.TryGetValue(partitionId, out capturedPump))
             {
                 // There already is a pump. Make sure the pump is working and replace the lease.
-                if (capturedPump.PumpStatus == PartitionPumpStatus.Errored || capturedPump.IsClosing)
+                if (capturedPump.PumpStatus != PartitionPumpStatus.Running && capturedPump.PumpStatus != PartitionPumpStatus.Opening)
                 {
                     // The existing pump is bad. Remove it.
                     await TryRemovePumpAsync(partitionId, CloseReason.Shutdown).ConfigureAwait(false);