diff --git a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/Commands/FailSpecialLiquidationInternalCommand.cs b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/Commands/FailSpecialLiquidationInternalCommand.cs index ce24515ba..1a425dc88 100644 --- a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/Commands/FailSpecialLiquidationInternalCommand.cs +++ b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/Commands/FailSpecialLiquidationInternalCommand.cs @@ -17,5 +17,8 @@ public class FailSpecialLiquidationInternalCommand [Key(2)] public string Reason { get; set; } + + [Key(3)] + public bool? CanRetryPriceRequest { get; set; } } } \ No newline at end of file diff --git a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationCommandsHandler.cs b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationCommandsHandler.cs index 99e6df59c..73c66cdf4 100644 --- a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationCommandsHandler.cs +++ b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationCommandsHandler.cs @@ -586,6 +586,7 @@ private async Task Handle(FailSpecialLiquidationInternalCommand command, IEventP OperationId = command.OperationId, CreationTime = _dateService.Now(), Reason = command.Reason, + CanRetryPriceRequest = command.CanRetryPriceRequest ?? false }); _chaosKitty.Meow(command.OperationId); diff --git a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationSaga.cs b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationSaga.cs index db18afb93..dc4b744a6 100644 --- a/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationSaga.cs +++ b/src/MarginTrading.Backend.Services/Workflow/SpecialLiquidation/SpecialLiquidationSaga.cs @@ -171,7 +171,8 @@ private async Task Handle(PriceForSpecialLiquidationCalculationFailedEvent e, IC { OperationId = e.OperationId, CreationTime = _dateService.Now(), - Reason = e.Reason + Reason = e.Reason, + CanRetryPriceRequest = true }, _cqrsContextNamesSettings.TradingEngine); _chaosKitty.Meow(e.OperationId);