fix: use correct kubeclient on lbsvc strategy while watching for job

Signed-off-by: Utku Ozdemir <uoz@protonmail.com>
utkuozdemir · Dec 7, 2021 · a12ea06 · a12ea06
1 parent 5dcd277
commit a12ea06
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/strategy/lbsvc.go b/internal/strategy/lbsvc.go
@@ -59,7 +59,7 @@ func (r *LbSvc) Run(e *task.Execution) (bool, error) {
 	}
 
 	showProgressBar := !e.Task.Migration.Options.NoProgressBar
-	kubeClient := s.ClusterClient.KubeClient
+	kubeClient := d.ClusterClient.KubeClient
 	jobName := destReleaseName + "-rsync"
 	err = k8s.WaitForJobCompletion(e.Logger, kubeClient, destNs, jobName, showProgressBar)
 	return true, err