diff --git a/src/Marten/Events/Aggregation/AggregationRuntime.cs b/src/Marten/Events/Aggregation/AggregationRuntime.cs index 6db151c542..5ff778accc 100644 --- a/src/Marten/Events/Aggregation/AggregationRuntime.cs +++ b/src/Marten/Events/Aggregation/AggregationRuntime.cs @@ -95,7 +95,10 @@ public async ValueTask ApplyChangesAsync(DocumentSessionBase session, { var operation = Storage.DeleteForId(slice.Id, slice.Tenant.TenantId); - await processPossibleSideEffects(session, slice).ConfigureAwait(false); + if (session is ProjectionDocumentSession { Mode: ShardExecutionMode.Continuous }) + { + await processPossibleSideEffects(session, slice).ConfigureAwait(false); + } session.QueueOperation(operation); return;