logged

kubernetes-sigs · Jun 19, 2024 · f857bd9 · f857bd9
1 parent 6373a53
commit f857bd9
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 0 deletions.
diff --git a/pkg/kwokctl/cmd/create/cluster/cluster.go b/pkg/kwokctl/cmd/create/cluster/cluster.go
@@ -265,6 +265,7 @@ func runE(ctx context.Context, flags *flagpole) error {
 	cleanUp := func() {}
 	if exist {
 		logger.Info("Cluster already exists")
+		logger.Log(log.LevelInfo, "inside 2 WaitReady")
 		if ready, err := rt.Ready(ctx); err == nil && ready {
 			logger.Info("Cluster is already ready")
 			return nil

diff --git a/pkg/kwokctl/runtime/binary/cluster.go b/pkg/kwokctl/runtime/binary/cluster.go
@@ -1198,6 +1198,7 @@ func (c *Cluster) WaitReady(ctx context.Context, timeout time.Duration) error {
 	)
 	logger := log.FromContext(ctx)
 	waitErr = wait.Poll(ctx, func(ctx context.Context) (bool, error) {
+		logger.Log(log.LevelInfo, "inside 3 WaitReady")
 		ready, err = c.Ready(ctx)
 		if err != nil {
 			logger.Debug("Cluster is not ready",

diff --git a/pkg/kwokctl/runtime/cluster.go b/pkg/kwokctl/runtime/cluster.go
@@ -367,6 +367,7 @@ func (c *Cluster) WaitReady(ctx context.Context, timeout time.Duration) error {
 	logger := log.FromContext(ctx)
 	waitErr = wait.Poll(ctx, func(ctx context.Context) (bool, error) {
 		ready, err = c.Ready(ctx)
+		logger.Log(log.LevelInfo, "inside 1 WaitReady")
 		if err != nil {
 			logger.Debug("Cluster is not ready",
 				"err", err,