diff --git a/src/bin/main.rs b/src/bin/main.rs index ecc57fc..7df0ba1 100644 --- a/src/bin/main.rs +++ b/src/bin/main.rs @@ -119,6 +119,9 @@ async fn run() -> anyhow::Result<()> { receiver, fees_grt, } => { + if aggregation_timestamp < start_timestamp { + continue; + } let key = IndexerFeesKey { signer, receiver }; let agg = aggregations.entry(aggregation_timestamp).or_default(); *agg.indexer_fees.entry(key).or_default() += fees_grt;