Revert "test"

This reverts commit 10d0cf7.
kubernetes-sigs · Nov 27, 2024 · 21968b4 · 21968b4
1 parent 10d0cf7
commit 21968b4
Show file tree

Hide file tree

Showing 4 changed files with 0 additions and 12 deletions.
diff --git a/pkg/kwok/controllers/node_controller.go b/pkg/kwok/controllers/node_controller.go
@@ -327,9 +327,6 @@ func (c *NodeController) playStageWorker(ctx context.Context) {
 		if !ok {
 			return
 		}
-		if c.delayQueue.Len() > 10 {
-			go c.playStageWorker(ctx)
-		}
 		c.delayQueueMapping.Delete(node.Key)
 		needRetry, err := c.playStage(ctx, node.Resource, node.Stage)
 		if err != nil {

diff --git a/pkg/kwok/controllers/node_lease_controller.go b/pkg/kwok/controllers/node_lease_controller.go
@@ -112,9 +112,6 @@ func (c *NodeLeaseController) syncWorker(ctx context.Context) {
 		if !ok {
 			return
 		}
-		if c.delayQueue.Len() > 10 {
-			go c.syncWorker(ctx)
-		}
 		first, ok := c.holdLeaseSet.Load(nodeName)
 		if !ok {
 			continue

diff --git a/pkg/kwok/controllers/pod_controller.go b/pkg/kwok/controllers/pod_controller.go
@@ -262,9 +262,6 @@ func (c *PodController) playStageWorker(ctx context.Context) {
 		if !ok {
 			return
 		}
-		if c.delayQueue.Len() > 10 {
-			go c.playStageWorker(ctx)
-		}
 		c.delayQueueMapping.Delete(pod.Key)
 		needRetry, err := c.playStage(ctx, pod.Resource, pod.Stage)
 		if err != nil {

diff --git a/pkg/kwok/controllers/stage_controller.go b/pkg/kwok/controllers/stage_controller.go
@@ -240,9 +240,6 @@ func (c *StageController) playStageWorker(ctx context.Context) {
 		if !ok {
 			return
 		}
-		if c.delayQueue.Len() > 10 {
-			go c.playStageWorker(ctx)
-		}
 		c.delayQueueMapping.Delete(resource.Key)
 		needRetry, err := c.playStage(ctx, resource.Resource, resource.Stage)
 		if err != nil {