@@ -22,6 +22,7 @@ import {
2222 UNIMIND_UPDATE_THRESHOLD ,
2323 UNIMIND_CIRCUIT_BREAKER_MAX_BATCH ,
2424 UNIMIND_CIRCUIT_BREAKER_MIN_ORDERS ,
25+ UNIMIND_CIRCUIT_BREAKER_FILL_RATE_THRESHOLD ,
2526} from '../util/constants'
2627import { median } from '../util/unimind'
2728
@@ -156,11 +157,11 @@ export async function updateParameters(
156157 const statistics = getStatistics ( pairOrders . orders , log )
157158 const batchMetrics = calculateBatchMetrics ( statistics )
158159
159- // Check circuit breaker: early batches with zero fill rate
160- const circuitBreakerTriggered = shouldCheckCircuitBreaker && batchMetrics . fillRate === 0
160+ // Check circuit breaker: early batches with low fill rate
161+ const circuitBreakerTriggered = shouldCheckCircuitBreaker && batchMetrics . fillRate <= UNIMIND_CIRCUIT_BREAKER_FILL_RATE_THRESHOLD
161162 if ( circuitBreakerTriggered ) {
162163 log . info (
163- `Unimind updateParameters: Circuit breaker triggered for pair ${ pairKey } (batch ${ pairData . batchNumber } ) - fillRate is 0 after ${ totalCount } orders`
164+ `Unimind updateParameters: Circuit breaker triggered for pair ${ pairKey } (batch ${ pairData . batchNumber } ) - fillRate ${ batchMetrics . fillRate } <= ${ UNIMIND_CIRCUIT_BREAKER_FILL_RATE_THRESHOLD } after ${ totalCount } orders`
164165 )
165166 }
166167
@@ -218,7 +219,7 @@ export async function updateParameters(
218219 log . info (
219220 `Unimind updateParameters: Circuit breaker not triggered for pair ${ pairKey } - fillRate ${ batchMetrics . fillRate . toFixed (
220221 3
221- ) } > 0 , not updating parameters yet`
222+ ) } > ${ UNIMIND_CIRCUIT_BREAKER_FILL_RATE_THRESHOLD } , not updating parameters yet`
222223 )
223224 // Update the count only
224225 await unimindParametersRepo . put ( {
0 commit comments