diff --git a/pkg/kwokctl/cmd/create/cluster/cluster.go b/pkg/kwokctl/cmd/create/cluster/cluster.go index 15cf72d327..80fe485eab 100644 --- 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 index 8ec2556366..47477fb18c 100644 --- 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 index 9fd7b25e59..fe2a85d6d4 100644 --- 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,