public Task OnErrorAsync()

in src/WebJobs.Extensions.CosmosDB/Trigger/CosmosDBTriggerHealthMonitor.cs [21:46]

• 24 lines of code
• 6 McCabe index (conditional complexity)

        public Task OnErrorAsync(string leaseToken, Exception exception)
        {
            switch (exception)
            {
                case ChangeFeedProcessorUserException userException:
                    this.logger.LogWarning(Events.OnError, userException.InnerException, "Lease {LeaseToken} encountered an unhandled user exception during processing.", leaseToken);
                    this.logger.LogDebug(Events.OnError, "Lease {LeaseToken} has error diagnostics {Diagnostics}", leaseToken, userException.ChangeFeedProcessorContext.Diagnostics);
                    break;
                case CosmosException cosmosException when cosmosException.StatusCode == HttpStatusCode.RequestTimeout || cosmosException.StatusCode == HttpStatusCode.ServiceUnavailable:
                    this.logger.LogWarning(Events.OnError, cosmosException, "Lease {LeaseToken} experiencing transient connectivity issues.", leaseToken);
                    break;
                case CosmosException cosmosException when cosmosException.StatusCode == HttpStatusCode.PreconditionFailed:
                    this.logger.LogInformation(Events.OnError, cosmosException, "Lease {LeaseToken} was lost. This is expected during scaling and briefly during initialization as the leases are rebalanced across instances.", leaseToken);
                    break;
                default:
                    this.logger.LogError(Events.OnError, exception, "Lease {LeaseToken} experienced an error during processing.", leaseToken);
                    break;
            }

            if (exception is CosmosException asCosmosException)
            {
                this.logger.LogDebug(Events.OnError, "Lease {LeaseToken} has error diagnostics {Diagnostics}", leaseToken, asCosmosException.Diagnostics);
            }

            return Task.CompletedTask;
        }