diff --git a/agent/agent.go b/agent/agent.go
index 2282a4f2..885ab9c3 100644
--- a/agent/agent.go
+++ b/agent/agent.go
@@ -279,7 +279,7 @@ func (r *Agent) setupSink(ctx context.Context, sr recipe.PluginRecipe, stream *s
 	}
 
 	retryNotification := func(e error, d time.Duration) {
-		for _, mt := range r.monitor{
+		for _, mt := range r.monitor {
 			mt.RecordSinkRetryCount(ctx, pluginInfo)
 		}