fix: dynamic client error in k8s fetch

scrapers/cron.go

@@ -228,6 +228,15 @@ func scheduleScraperJob(sc api.ScrapeContext) error {
 	}
 
 	for _, config := range sc.ScrapeConfig().Spec.Kubernetes {
+		// Update scrape context with provided kubeconfig
+		if config.Kubeconfig != nil {
+			c, err := sc.WithKubeconfig(*config.Kubeconfig)
+			if err != nil {
+				return fmt.Errorf("failed to apply custom kubeconfig: %w", err)
+			}
+			sc.Context = *c
+		}
+
 		if sc.PropertyOn(false, "watch.disable") {
 			config.Watch = []v1.KubernetesResourceToWatch{}
 		} else if len(config.Watch) == 0 {
@@ -242,14 +251,6 @@ func scheduleScraperJob(sc api.ScrapeContext) error {
 			return fmt.Errorf("failed to watch kubernetes resources: %v", err)
 		}
 
-		if config.Kubeconfig != nil {
-			c, err := sc.WithKubeconfig(*config.Kubeconfig)
-			if err != nil {
-				return fmt.Errorf("failed to apply custom kubeconfig: %w", err)
-			}
-			sc.Context = *c
-
-		}
 		watchConsumerJob := ConsumeKubernetesWatchJobFunc(sc, config, queue)
 		if err := watchConsumerJob.AddToScheduler(scrapeJobScheduler); err != nil {
 			return fmt.Errorf("failed to schedule kubernetes watch consumer job: %v", err)

scrapers/incremental.go

@@ -115,6 +115,14 @@ func ConsumeKubernetesWatchJobFunc(sc api.ScrapeContext, config v1.Kubernetes, q
 
 					cc := api.NewScrapeContext(ctx.Context).WithScrapeConfig(sc.ScrapeConfig()).WithJobHistory(ctx.History).AsIncrementalScrape()
 					cc.Context = cc.Context.WithoutName().WithName(fmt.Sprintf("watch[%s/%s]", cc.GetNamespace(), cc.GetName()))
+					if config.Kubeconfig != nil {
+						c, err := cc.WithKubeconfig(*config.Kubeconfig)
+						if err != nil {
+							ctx.History.AddErrorf("failed to apply custom kubeconfig: %v", err)
+							return
+						}
+						cc.Context = *c
+					}
 
 					backoff := retry.WithMaxRetries(3, retry.NewExponential(time.Second))
 					err := retry.Do(ctx, backoff, func(_ctx gocontext.Context) error {