fix: do not spam the DB

vegaprotocol · Oct 16, 2023 · 960d44d · 960d44d
1 parent 5949477
commit 960d44d
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/core/execution/common/liquidity_provision.go b/core/execution/common/liquidity_provision.go
@@ -308,7 +308,10 @@ func (m *MarketLiquidity) OnEpochEnd(ctx context.Context, t time.Time) {
 	m.calculateAndDistribute(ctx, t)
 
 	// report liquidity fees allocation stats
-	m.broker.Send(events.NewPaidLiquidityFeesStatsEvent(ctx, m.liquidityEngine.PaidLiquidityFeesStats().ToProto(m.marketID, m.asset)))
+	feeStats := m.liquidityEngine.PaidLiquidityFeesStats()
+	if !feeStats.TotalFeesPaid.IsZero() {
+		m.broker.Send(events.NewPaidLiquidityFeesStatsEvent(ctx, feeStats.ToProto(m.marketID, m.asset)))
+	}
 }
 
 func (m *MarketLiquidity) OnMarketClosed(ctx context.Context, t time.Time) {