feat(GcpVpcPeering): print current state during wait (#837)

kyma-project · Nov 28, 2024 · 12cb732 · 12cb732
1 parent d236db0
commit 12cb732
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 4 deletions.
diff --git a/pkg/kcp/provider/gcp/vpcpeering/waitRemoteVpcPeeringAvailable.go b/pkg/kcp/provider/gcp/vpcpeering/waitRemoteVpcPeeringAvailable.go
@@ -1,8 +1,9 @@
 package vpcpeering
 
 import (
-	pb "cloud.google.com/go/compute/apiv1/computepb"
 	"context"
+
+	pb "cloud.google.com/go/compute/apiv1/computepb"
 	"github.com/kyma-project/cloud-manager/pkg/composed"
 	"github.com/kyma-project/cloud-manager/pkg/util"
 )
@@ -13,7 +14,7 @@ func waitRemoteVpcPeeringAvailable(ctx context.Context, st composed.State) (erro
 
 	if state.remoteVpcPeering.GetState() != pb.NetworkPeering_INACTIVE.String() &&
 		state.remoteVpcPeering.GetState() != pb.NetworkPeering_ACTIVE.String() {
-		logger.Info("GCP Remote VPC Peering is not ready yet, re-queueing with delay")
+		logger.Info("GCP Remote VPC Peering is not ready yet, re-queueing with delay", "currentState", state.remoteVpcPeering.GetState())
 		return composed.StopWithRequeueDelay(util.Timing.T10000ms()), nil
 	}
 

diff --git a/pkg/kcp/provider/gcp/vpcpeering/waitVpcPeeringActive.go b/pkg/kcp/provider/gcp/vpcpeering/waitVpcPeeringActive.go
@@ -1,8 +1,9 @@
 package vpcpeering
 
 import (
-	pb "cloud.google.com/go/compute/apiv1/computepb"
 	"context"
+
+	pb "cloud.google.com/go/compute/apiv1/computepb"
 	"github.com/kyma-project/cloud-manager/pkg/composed"
 	"github.com/kyma-project/cloud-manager/pkg/util"
 )
@@ -12,7 +13,7 @@ func waitVpcPeeringActive(ctx context.Context, st composed.State) (error, contex
 	logger := composed.LoggerFromCtx(ctx)
 
 	if state.kymaVpcPeering.GetState() != pb.NetworkPeering_ACTIVE.String() && state.remoteVpcPeering.GetState() != pb.NetworkPeering_ACTIVE.String() {
-		logger.Info("GCP VPC Peering is not ready yet, re-queueing with delay")
+		logger.Info("GCP VPC Peering is not ready yet, re-queueing with delay", "currentState", state.remoteVpcPeering.GetState())
 		return composed.StopWithRequeueDelay(util.Timing.T10000ms()), nil
 	}