diff --git a/processes/consumer/process.go b/processes/consumer/process.go
index 60363910d..421f605a7 100644
--- a/processes/consumer/process.go
+++ b/processes/consumer/process.go
@@ -75,7 +75,6 @@ func (p processArgs) process(ctx context.Context, cfg config.Config, inMemDB *mo
 
 	// 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"