diff --git a/plugins/source/k8s/resources/plugin/plugin.go b/plugins/source/k8s/resources/plugin/plugin.go
index 1974b8d8c6314e..27fa94292d692d 100644
--- a/plugins/source/k8s/resources/plugin/plugin.go
+++ b/plugins/source/k8s/resources/plugin/plugin.go
@@ -91,7 +91,11 @@ func newClient(ctx context.Context, logger zerolog.Logger, specBytes []byte, opt
 		return nil, err
 	}
 	c.syncClient = syncClient.(*client.Client)
-	c.scheduler = scheduler.NewScheduler(scheduler.WithLogger(logger), scheduler.WithConcurrency(s.Concurrency), scheduler.WithInvocationID(options.InvocationID))
+	c.scheduler = scheduler.NewScheduler(
+		scheduler.WithLogger(logger),
+		scheduler.WithConcurrency(s.Concurrency),
+		scheduler.WithInvocationID(options.InvocationID),
+	)
 	return c, nil
 }