yetanotherco
diff --git a/‎aggregator/internal/pkg/aggregator.go‎
Lines changed: 1 addition & 0 deletions b/‎aggregator/internal/pkg/aggregator.go‎
Lines changed: 1 addition & 0 deletions
@@ -372,6 +372,7 @@ func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]by
 		agg.logger.Fatalf("BLS aggregation service error when initializing new task: %s", err)
 	}
 
+	agg.metrics.IncAggregatorReceivedTasks()
 	agg.taskMutex.Unlock()
 	agg.AggregatorConfig.BaseConfig.Logger.Info("- Unlocked Resources: Adding new task")
 	agg.logger.Info("New task added", "batchIndex", batchIndex, "batchIdentifierHash", "0x"+hex.EncodeToString(batchIdentifierHash[:]))
Original file line number	Diff line number	Diff line change
`@@ -372,6 +372,7 @@ func (agg *Aggregator) AddNewTask(batchMerkleRoot [32]byte, senderAddress [20]by`
`372`	`372`	`agg.logger.Fatalf("BLS aggregation service error when initializing new task: %s", err)`
`373`	`373`	`}`
`374`	`374`
	`375`	`+ agg.metrics.IncAggregatorReceivedTasks()`
`375`	`376`	`agg.taskMutex.Unlock()`
`376`	`377`	`agg.AggregatorConfig.BaseConfig.Logger.Info("- Unlocked Resources: Adding new task")`
`377`	`378`	`agg.logger.Info("New task added", "batchIndex", batchIndex, "batchIdentifierHash", "0x"+hex.EncodeToString(batchIdentifierHash[:]))`