Push metrics when there is no unbonding txs

babylonchain · Jun 3, 2024 · 0f8da6b · 0f8da6b
2 parents 98ad1d6 + 03c3db5
commit 0f8da6b
Showing 1 changed file with 10 additions and 10 deletions.
diff --git a/internal/services/unbonding_pipeline.go b/internal/services/unbonding_pipeline.go
@@ -374,11 +374,6 @@ func (up *UnbondingPipeline) ProcessNewTransactions(ctx context.Context) error {
 		return err
 	}
 
-	if len(unbondingTransactions) == 0 {
-		up.logger.Info("No unbonding new transactions to process")
-		return nil
-	}
-
 	defer func() {
 		if up.Metrics.Config.Enabled {
 			if err := up.pushMetrics(); err != nil {
@@ -387,6 +382,11 @@ func (up *UnbondingPipeline) ProcessNewTransactions(ctx context.Context) error {
 		}
 	}()
 
+	if len(unbondingTransactions) == 0 {
+		up.logger.Info("No unbonding new transactions to process")
+		return nil
+	}
+
 	if err := up.processUnbondingTransactions(ctx, unbondingTransactions); err != nil {
 		return err
 	}
@@ -404,11 +404,6 @@ func (up *UnbondingPipeline) ProcessFailedTransactions(ctx context.Context) erro
 		return err
 	}
 
-	if len(unbondingTransactions) == 0 {
-		up.logger.Info("No failed unbonding transactions to process")
-		return nil
-	}
-
 	defer func() {
 		if up.Metrics.Config.Enabled {
 			if err := up.pushMetrics(); err != nil {
@@ -417,6 +412,11 @@ func (up *UnbondingPipeline) ProcessFailedTransactions(ctx context.Context) erro
 		}
 	}()
 
+	if len(unbondingTransactions) == 0 {
+		up.logger.Info("No failed unbonding transactions to process")
+		return nil
+	}
+
 	if err := up.processUnbondingTransactions(ctx, unbondingTransactions); err != nil {
 		return err
 	}