commands: update for logging

Signed-off-by: Javier <[email protected]>

pkg/crds/crds.go

@@ -27,6 +27,8 @@ import (
 	"k8s.io/apimachinery/pkg/apis/meta/v1/unstructured"
 	"k8s.io/apimachinery/pkg/types"
 	"k8s.io/client-go/kubernetes"
+	"log"
+	"time"
 )
 
 var cephResources = []string{
@@ -176,6 +178,8 @@ func updatingFinalizers(ctx context.Context, clientsets k8sutil.ClientsetsInterf
 
 func ensureClusterIsEmpty(ctx context.Context, k8sClientSet kubernetes.Interface, clientsets k8sutil.ClientsetsInterface, clusterNamespace string) {
 	logging.Info("waiting to clean up resources")
+	logging.Info("awaiting")
+	time.Sleep(10 * time.Second)
 	for {
 		pods, err := k8sClientSet.CoreV1().Pods(clusterNamespace).List(ctx, v1.ListOptions{LabelSelector: "rook_cluster=" + clusterNamespace})
 		if err != nil {
@@ -194,5 +198,7 @@ func ensureClusterIsEmpty(ctx context.Context, k8sClientSet kubernetes.Interface
 				logging.Fatal(err)
 			}
 		}
+		time.Sleep(10 * time.Second)
+		log.Fatalln("die by taking a lot of time")
 	}
 }