Remove redundant shutdown log

jet · Aug 22, 2023 · b47c08d · b47c08d
1 parent a1ed78d
commit b47c08d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/Propulsion.CosmosStore/ChangeFeedProcessor.fs b/src/Propulsion.CosmosStore/ChangeFeedProcessor.fs
@@ -112,7 +112,9 @@ type ChangeFeedProcessor =
  (changes : IReadOnlyCollection<System.Text.Json.JsonDocument>)
 #endif
  (checkpointAsync : CancellationToken -> Task<unit>) ct = task {
- let log (e : exn) = log.Error(e, "Reader {processorName}/{partition} Handler Threw", processorName, context.LeaseToken)
+ let log: exn -> unit = function
+ | :? OperationCanceledException -> () // Shutdown via .Stop triggers this
+ | e -> log.Error(e, "Reader {processorName}/{partition} Handler Threw", processorName, context.LeaseToken)
  try let ctx = { source = monitored; group = processorName
  epoch = context.Headers.ContinuationToken.Trim[|'"'|] |> int64
 #if COSMOSV3