diff --git a/services/bls_aggregation/blsagg.go b/services/bls_aggregation/blsagg.go index 83525be5..bdab6691 100644 --- a/services/bls_aggregation/blsagg.go +++ b/services/bls_aggregation/blsagg.go @@ -235,7 +235,7 @@ func (a *BlsAggregatorService) singleTaskAggregatorGoroutineFunc( } operatorsAvsStateDict, err := a.avsRegistryService.GetOperatorsAvsStateAtBlock(context.Background(), quorumNumbers, taskCreatedBlock) if err != nil { - a.logger.Debug("Task goroutine failed to get operators state from avs registry", "taskIndex", taskIndex, "err", err) + a.logger.Error("Task goroutine failed to get operators state from avs registry", "taskIndex", taskIndex, "err", err) a.aggregatedResponsesC <- BlsAggregationServiceResponse{ Err: TaskInitializationErrorFn(fmt.Errorf("AggregatorService failed to get operators state from avs registry at blockNum %d: %w", taskCreatedBlock, err), taskIndex), TaskIndex: taskIndex, @@ -244,6 +244,7 @@ func (a *BlsAggregatorService) singleTaskAggregatorGoroutineFunc( } quorumsAvsStakeDict, err := a.avsRegistryService.GetQuorumsAvsStateAtBlock(context.Background(), quorumNumbers, taskCreatedBlock) if err != nil { + a.logger.Error("Task goroutine failed to get quorums state from avs registry", "taskIndex", taskIndex, "err", err) a.aggregatedResponsesC <- BlsAggregationServiceResponse{ Err: TaskInitializationErrorFn(fmt.Errorf("Aggregator failed to get quorums state from avs registry: %w", err), taskIndex), TaskIndex: taskIndex,