diff --git a/packages/brain/src/index.ts b/packages/brain/src/index.ts index 0a82cdc6..791755a5 100644 --- a/packages/brain/src/index.ts +++ b/packages/brain/src/index.ts @@ -103,15 +103,18 @@ const proofOfValidationCron = new CronJob(shareCronInterval, () => proofOfValidationCron.start(); // execute the performance cron task every 1/4 of an epoch -export const trackValidatorsPerformanceCronTask = new CronJob((slotsPerEpoch * secondsPerSlot) / 4 * 1000, async () => { - await trackValidatorsPerformanceCron({ - brainDb, - postgresClient, - beaconchainApi, - executionClient, - consensusClient - }); -}); +export const trackValidatorsPerformanceCronTask = new CronJob( + ((slotsPerEpoch * secondsPerSlot) / 4) * 1000, + async () => { + await trackValidatorsPerformanceCron({ + brainDb, + postgresClient, + beaconchainApi, + executionClient, + consensusClient + }); + } +); trackValidatorsPerformanceCronTask.start(); // Graceful shutdown diff --git a/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts b/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts index 57eccea2..60d38c2d 100644 --- a/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts +++ b/packages/brain/src/modules/cron/trackValidatorsPerformance/trackValidatorsPerformance.ts @@ -27,7 +27,7 @@ export async function trackValidatorsPerformanceCron({ }): Promise { try { const currentEpoch = await beaconchainApi.getEpochHeader({ blockId: "finalized" }); - + if (currentEpoch !== lastProcessedEpoch) { await fetchAndInsertPerformanceCron({ brainDb,