diff --git a/yarn-project/archiver/src/modules/data_store_updater.ts b/yarn-project/archiver/src/modules/data_store_updater.ts index 83864240f01d..f1a0ed35fc51 100644 --- a/yarn-project/archiver/src/modules/data_store_updater.ts +++ b/yarn-project/archiver/src/modules/data_store_updater.ts @@ -178,7 +178,7 @@ export class ArchiverDataStoreUpdater { this.log.verbose(`Block number ${blockNumber} already inserted and matches checkpoint`, blockInfos); lastAlreadyInsertedBlockNumber = blockNumber; } else { - this.log.warn(`Conflict detected at block ${blockNumber} between checkpointed and local block`, blockInfos); + this.log.info(`Conflict detected at block ${blockNumber} between checkpointed and local block`, blockInfos); const prunedBlocks = await this.removeBlocksAfter(BlockNumber(blockNumber - 1)); return { prunedBlocks, lastAlreadyInsertedBlockNumber }; } diff --git a/yarn-project/archiver/src/modules/l1_synchronizer.ts b/yarn-project/archiver/src/modules/l1_synchronizer.ts index 221d50336fb7..a0ee3d3971f6 100644 --- a/yarn-project/archiver/src/modules/l1_synchronizer.ts +++ b/yarn-project/archiver/src/modules/l1_synchronizer.ts @@ -828,7 +828,7 @@ export class ArchiverL1Synchronizer implements Traceable { const prunedCheckpointNumber = result.prunedBlocks[0].checkpointNumber; const prunedSlotNumber = result.prunedBlocks[0].header.globalVariables.slotNumber; - this.log.warn( + this.log.info( `Pruned ${result.prunedBlocks.length} mismatching blocks for checkpoint ${prunedCheckpointNumber}`, { prunedBlocks: result.prunedBlocks.map(b => b.toBlockInfo()), prunedSlotNumber, prunedCheckpointNumber }, ); diff --git a/yarn-project/p2p/src/services/libp2p/libp2p_service.ts b/yarn-project/p2p/src/services/libp2p/libp2p_service.ts index d467d60ae734..2903cb09bda2 100644 --- a/yarn-project/p2p/src/services/libp2p/libp2p_service.ts +++ b/yarn-project/p2p/src/services/libp2p/libp2p_service.ts @@ -1192,7 +1192,7 @@ export class LibP2PService extends WithTracer implements P2PService { // Note: Validators do NOT attest to individual blocks, only to checkpoint proposals. const isValid = await this.blockReceivedCallback(block, sender); if (!isValid) { - this.logger.warn(`Block proposal validation failed for block ${block.blockNumber}`, block.toBlockInfo()); + this.logger.info(`Block proposal validation failed for block ${block.blockNumber}`, block.toBlockInfo()); } } diff --git a/yarn-project/validator-client/src/key_store/ha_key_store.ts b/yarn-project/validator-client/src/key_store/ha_key_store.ts index a6fd29bcd9d3..91c8279642e9 100644 --- a/yarn-project/validator-client/src/key_store/ha_key_store.ts +++ b/yarn-project/validator-client/src/key_store/ha_key_store.ts @@ -240,7 +240,7 @@ export class HAKeyStore implements ExtendedValidatorKeyStore { } if (error instanceof SlashingProtectionError) { - this.log.warn(`Duty already signed by another node with different payload`, { + this.log.info(`Duty already signed by another node with different payload`, { dutyType: context.dutyType, slot: context.slot, existingMessageHash: error.existingMessageHash, diff --git a/yarn-project/validator-client/src/validator.ts b/yarn-project/validator-client/src/validator.ts index baec6d4f2317..60ee9c8ea2d2 100644 --- a/yarn-project/validator-client/src/validator.ts +++ b/yarn-project/validator-client/src/validator.ts @@ -380,7 +380,7 @@ export class ValidatorClient extends (EventEmitter as new () => WatcherEmitter) // Ignore proposals from ourselves (may happen in HA setups) if (this.getValidatorAddresses().some(addr => addr.equals(proposer))) { - this.log.warn(`Ignoring block proposal from self for slot ${slotNumber}`, { + this.log.debug(`Ignoring block proposal from self for slot ${slotNumber}`, { proposer: proposer.toString(), slotNumber, }); @@ -416,9 +416,10 @@ export class ValidatorClient extends (EventEmitter as new () => WatcherEmitter) ); if (!validationResult.isValid) { - this.log.warn(`Block proposal validation failed: ${validationResult.reason}`, proposalInfo); - const reason = validationResult.reason || 'unknown'; + + this.log.warn(`Block proposal validation failed: ${reason}`, proposalInfo); + // Classify failure reason: bad proposal vs node issue const badProposalReasons: BlockProposalValidationFailureReason[] = [ 'invalid_proposal', @@ -490,7 +491,7 @@ export class ValidatorClient extends (EventEmitter as new () => WatcherEmitter) // Ignore proposals from ourselves (may happen in HA setups) if (this.getValidatorAddresses().some(addr => addr.equals(proposer))) { - this.log.warn(`Ignoring block proposal from self for slot ${slotNumber}`, { + this.log.debug(`Ignoring block proposal from self for slot ${slotNumber}`, { proposer: proposer.toString(), slotNumber, }); diff --git a/yarn-project/validator-ha-signer/src/slashing_protection_service.ts b/yarn-project/validator-ha-signer/src/slashing_protection_service.ts index ac344c1f379e..0b7d97f15ea8 100644 --- a/yarn-project/validator-ha-signer/src/slashing_protection_service.ts +++ b/yarn-project/validator-ha-signer/src/slashing_protection_service.ts @@ -99,7 +99,7 @@ export class SlashingProtectionService { if (isNew) { // We successfully acquired the lock - this.log.info(`Acquired lock for duty ${dutyType} at slot ${slot}`, { + this.log.verbose(`Acquired lock for duty ${dutyType} at slot ${slot}`, { validatorAddress: validatorAddress.toString(), nodeId, }); @@ -177,7 +177,7 @@ export class SlashingProtectionService { ); if (success) { - this.log.info(`Recorded successful signing for duty ${dutyType} at slot ${slot}`, { + this.log.verbose(`Recorded successful signing for duty ${dutyType} at slot ${slot}`, { validatorAddress: validatorAddress.toString(), nodeId, }); diff --git a/yarn-project/world-state/src/synchronizer/server_world_state_synchronizer.ts b/yarn-project/world-state/src/synchronizer/server_world_state_synchronizer.ts index ad85df243053..c6d77400acb7 100644 --- a/yarn-project/world-state/src/synchronizer/server_world_state_synchronizer.ts +++ b/yarn-project/world-state/src/synchronizer/server_world_state_synchronizer.ts @@ -405,7 +405,7 @@ export class ServerWorldStateSynchronizer } private async handleChainPruned(blockNumber: BlockNumber) { - this.log.warn(`Chain pruned to block ${blockNumber}`); + this.log.info(`Chain pruned to block ${blockNumber}`); const status = await this.merkleTreeDb.unwindBlocks(blockNumber); this.provenBlockNumber = undefined; this.instrumentation.updateWorldStateMetrics(status);