Ensure TrySetException is always set on exception

Author: ramonsmits

src/ServiceControl.Audit/Auditing/AuditIngestion.cs

@@ -223,19 +223,20 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                             await auditIngestor.Ingest(contexts);
                         }
                     }
-                    catch (OperationCanceledException) when (stoppingToken.IsCancellationRequested)
+                    catch (Exception e)
                     {
-                        throw; // Catch again in outer catch
-                    }
-                    catch (Exception e) // show must go on
-                    {
-                        logger.Info("Ingesting messages failed", e);
-
                         // signal all message handling tasks to terminate
                         foreach (var context in contexts)
                         {
-                            context.GetTaskCompletionSource().TrySetException(e);
+                            _ = context.GetTaskCompletionSource().TrySetException(e);
                         }
+
+                        if (e is OperationCanceledException && stoppingToken.IsCancellationRequested)
+                        {
+                            break; // ExecuteAsync cancelled
+                        }
+
+                        logger.Info("Ingesting messages failed", e);
                     }
                     finally
                     {

src/ServiceControl/Operations/ErrorIngestion.cs

@@ -99,19 +99,20 @@ protected override async Task ExecuteAsync(CancellationToken stoppingToken)
                             await ingestor.Ingest(contexts);
                         }
                     }
-                    catch (OperationCanceledException) when (stoppingToken.IsCancellationRequested)
+                    catch (Exception e)
                     {
-                        throw; // Catch again in outer catch
-                    }
-                    catch (Exception e) // show must go on
-                    {
-                        Logger.Info("Ingesting messages failed", e);
-
                         // signal all message handling tasks to terminate
                         foreach (var context in contexts)
                         {
-                            context.GetTaskCompletionSource().TrySetException(e);
+                            _ = context.GetTaskCompletionSource().TrySetException(e);
                         }
+
+                        if (e is OperationCanceledException && stoppingToken.IsCancellationRequested)
+                        {
+                            break; // ExecuteAsync cancelled
+                        }
+
+                        Logger.Info("Ingesting messages failed", e);
                     }
                     finally
                     {