From 4043af0f2173c0f26a0bcd9c2e349a657607bf9e Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Wed, 25 Sep 2024 20:22:58 -0700 Subject: [PATCH] Remove extra line. --- processes/consumer/process.go | 1 - 1 file changed, 1 deletion(-) 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"