From c5a6f3fbe7fbfca69c20677b1ffce23ae03118d0 Mon Sep 17 00:00:00 2001 From: Aleksandr Tretiakov Date: Wed, 11 Dec 2024 15:14:04 +0300 Subject: [PATCH] Removed circuit breaker --- .../src/processors/newSignatureProcessor.ts | 9 ++------- 1 file changed, 2 insertions(+), 7 deletions(-) diff --git a/automated-orders/packages/blockchain-library/src/processors/newSignatureProcessor.ts b/automated-orders/packages/blockchain-library/src/processors/newSignatureProcessor.ts index a55cf655d..494395448 100644 --- a/automated-orders/packages/blockchain-library/src/processors/newSignatureProcessor.ts +++ b/automated-orders/packages/blockchain-library/src/processors/newSignatureProcessor.ts @@ -17,13 +17,8 @@ export class NewSignatureProcessor extends Processor { super(generator); const retryPolicy = retry(handleAll, { maxAttempts: 3, backoff: new ExponentialBackoff() }); - - const circuitBreakerPolicy = circuitBreaker(handleAll, { - halfOpenAfter: 10 * 1000, - breaker: new ConsecutiveBreaker(5), - }); - - this.retryPolicy = wrap(retryPolicy, circuitBreakerPolicy); + // TODO AT: Add circuit breaker + this.retryPolicy = retryPolicy; } async handle(data: INewSignatureRequest): Promise {