diff --git a/TransactionProcessor.BusinessLogic/Services/FloatDomainService.cs b/TransactionProcessor.BusinessLogic/Services/FloatDomainService.cs
index 4fffc9f..dea1fdb 100644
--- a/TransactionProcessor.BusinessLogic/Services/FloatDomainService.cs
+++ b/TransactionProcessor.BusinessLogic/Services/FloatDomainService.cs
@@ -132,7 +132,7 @@ public async Task<Result> RecordCreditPurchase(FloatActivityCommands.RecordCredi
             {
                 Guid floatActivityAggregateId = IdGenerationService.GenerateFloatActivityAggregateId(command.EstateId, command.FloatId, command.CreditPurchasedDateTime.Date);
 
-                Result<FloatActivityAggregate> getFloatActivityResult = await DomainServiceHelper.GetAggregateOrFailure(ct => this.AggregateService.GetLatest<FloatActivityAggregate>(floatActivityAggregateId, ct), floatActivityAggregateId, cancellationToken);
+                Result<FloatActivityAggregate> getFloatActivityResult = await DomainServiceHelper.GetAggregateOrFailure(ct => this.AggregateService.GetLatest<FloatActivityAggregate>(floatActivityAggregateId, ct), floatActivityAggregateId, cancellationToken, false);
                 if (getFloatActivityResult.IsFailed)
                     return ResultHelpers.CreateFailure(getFloatActivityResult);
 
@@ -165,7 +165,7 @@ public async Task<Result> RecordTransaction(FloatActivityCommands.RecordTransact
                 // Generate the id for the activity aggregate
                 Guid floatActivityAggregateId = IdGenerationService.GenerateFloatActivityAggregateId(command.EstateId, floatId, getTransactionResult.Data.TransactionDateTime.Date);
 
-                Result<FloatActivityAggregate> getFloatActivityResult = await DomainServiceHelper.GetAggregateOrFailure(ct => this.AggregateService.GetLatest<FloatActivityAggregate>(floatActivityAggregateId, ct), floatActivityAggregateId, cancellationToken);
+                Result<FloatActivityAggregate> getFloatActivityResult = await DomainServiceHelper.GetAggregateOrFailure(ct => this.AggregateService.GetLatest<FloatActivityAggregate>(floatActivityAggregateId, ct), floatActivityAggregateId, cancellationToken, false);
                 if (getFloatActivityResult.IsFailed)
                     return ResultHelpers.CreateFailure(getFloatActivityResult);