Skip to content

Commit

Permalink
fix WatchDeploymentLogsByNameInput in autoscaler
Browse files Browse the repository at this point in the history
  • Loading branch information
Yuvaraj Kakaraparthi committed Apr 12, 2023
1 parent 264d162 commit 8c3bdc8
Showing 1 changed file with 1 addition and 10 deletions.
11 changes: 1 addition & 10 deletions test/framework/autoscaler_helpers.go
Original file line number Diff line number Diff line change
Expand Up @@ -162,23 +162,14 @@ func ApplyAutoscalerToWorkloadCluster(ctx context.Context, input ApplyAutoscaler
}

Expect(input.WorkloadClusterProxy.GetClient().Get(ctx, client.ObjectKeyFromObject(deployment), deployment)).To(Succeed())
// Get all the pods and dump them.
pods := &corev1.PodList{}
for i := 0; i < 12; i++ {
Expect(input.WorkloadClusterProxy.GetClient().List(ctx, pods, client.InNamespace("cluster-autoscaler-system"))).To(Succeed())
log.Logf("The pods are:")
log.Logf("%v", pods)
time.Sleep(10 * time.Second)
}

WaitForDeploymentsAvailable(ctx, WaitForDeploymentsAvailableInput{
Getter: input.WorkloadClusterProxy.GetClient(),
Deployment: deployment,
}, intervals...)

// Start streaming logs from all controller providers
WatchDeploymentLogsByName(ctx, WatchDeploymentLogsByNameInput{
GetLister: input.WorkloadClusterProxy.GetClient(),
Cache: input.WorkloadClusterProxy.GetCache(ctx),
ClientSet: input.WorkloadClusterProxy.GetClientSet(),
Deployment: deployment,
LogPath: filepath.Join(input.ArtifactFolder, "clusters", input.WorkloadClusterProxy.GetName(), "logs", deployment.GetNamespace()),
Expand Down

0 comments on commit 8c3bdc8

Please sign in to comment.