From c2c63afd8797679773829674c2edcda7bbcd2e94 Mon Sep 17 00:00:00 2001 From: Ruben Bartelink Date: Tue, 2 Apr 2019 15:34:34 +0100 Subject: [PATCH] Log large event stream name --- equinox-sync/Sync/Program.fs | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/equinox-sync/Sync/Program.fs b/equinox-sync/Sync/Program.fs index cc92da2b5..b498176e9 100644 --- a/equinox-sync/Sync/Program.fs +++ b/equinox-sync/Sync/Program.fs @@ -748,11 +748,10 @@ let enumEvents (xs : EventStore.ClientAPI.ResolvedEvent[]) = seq { || e.EventType.StartsWith("compacted",StringComparison.OrdinalIgnoreCase) || e.EventStreamId.StartsWith("$") || e.EventStreamId.EndsWith("_checkpoints") - || e.EventStreamId.EndsWith("_checkpoint") - || e.EventStreamId = "thor_useast2_to_backup_qa2_main" -> + || e.EventStreamId.EndsWith("_checkpoint") -> Choice2Of2 e | e when eb > Ingester.cosmosPayloadLimit -> - Log.Error("ES Event Id {eventId} size {eventSize} exceeds Cosmos ingestion limit {maxCosmosBytes}", e.EventId, eb, Ingester.cosmosPayloadLimit) + Log.Error("ES Event Id {eventId} (#{index} in {stream}, type {type}) size {eventSize} exceeds Cosmos ingestion limit {maxCosmosBytes}", e.EventId, e.EventNumber, e.EventStreamId, e.EventType, eb, Ingester.cosmosPayloadLimit) Choice2Of2 e | e -> Choice1Of2 (e.EventStreamId, e.EventNumber, Equinox.Codec.Core.EventData.Create(e.EventType, e.Data, e.Metadata, e.Timestamp)) }