Skip to content

Commit a5ff34c

Browse files
authored
Merge pull request #95 from zachaller/fix-ordering
🐛 Fix sync ordering for kubeconfig provider
2 parents a5fd846 + 9014e9c commit a5ff34c

File tree

1 file changed

+8
-9
lines changed

1 file changed

+8
-9
lines changed

providers/kubeconfig/provider.go

Lines changed: 8 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -286,6 +286,14 @@ func (p *Provider) createAndEngageCluster(ctx context.Context, clusterName strin
286286
}
287287
}()
288288

289+
// Engage cluster so that the manager can start operating on the cluster
290+
if err := p.mgr.Engage(clusterCtx, clusterName, cl); err != nil {
291+
cancel()
292+
return fmt.Errorf("failed to engage manager: %w", err)
293+
}
294+
295+
log.Info("Successfully engaged manager")
296+
289297
// Wait for cache to be ready
290298
log.Info("Waiting for cluster cache to be ready")
291299
if !cl.GetCache().WaitForCacheSync(clusterCtx) {
@@ -301,17 +309,8 @@ func (p *Provider) createAndEngageCluster(ctx context.Context, clusterName strin
301309
Cancel: cancel,
302310
Hash: hashStr,
303311
})
304-
305312
log.Info("Successfully added cluster")
306313

307-
// Engage cluster so that the manager can start operating on the cluster
308-
if err := p.mgr.Engage(clusterCtx, clusterName, cl); err != nil {
309-
log.Error(err, "Failed to engage manager, removing cluster")
310-
p.removeCluster(clusterName)
311-
return fmt.Errorf("failed to engage manager: %w", err)
312-
}
313-
314-
log.Info("Successfully engaged manager")
315314
return nil
316315
}
317316

0 commit comments

Comments
 (0)