From ad40320a39649ad8f15b88cab6828cedd1eac512 Mon Sep 17 00:00:00 2001
From: Robin Tang <rtang.cs@gmail.com>
Date: Wed, 25 Sep 2024 20:22:18 -0700
Subject: [PATCH] Update comment.

---
 processes/consumer/process.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/processes/consumer/process.go b/processes/consumer/process.go
index 60636e930..60363910d 100644
--- a/processes/consumer/process.go
+++ b/processes/consumer/process.go
@@ -64,9 +64,6 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo
 		return "", fmt.Errorf("cannot convert to memory event: %w", err)
 	}
 
-	// Emit event execution time.
-	evt.EmitExecutionTimeLag(metricsClient, cfg.Mode)
-
 	// Table name is only available after event has been cast
 	tags["table"] = evt.Table
 	if topicConfig.tc.ShouldSkip(_event.Operation()) {
@@ -76,6 +73,9 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo
 		return evt.Table, nil
 	}
 
+	// Emit execution time lag for non-skipped events.
+	evt.EmitExecutionTimeLag(metricsClient, cfg.Mode)
+
 	shouldFlush, flushReason, err := evt.Save(cfg, inMemDB, topicConfig.tc, p.Msg)
 	if err != nil {
 		tags["what"] = "save_fail"