From e28c13f819b2f6c2e3c5dc78a0a2e26df56bb473 Mon Sep 17 00:00:00 2001
From: Tamal Saha <tamal@appscode.com>
Date: Mon, 9 Oct 2017 21:44:37 -0700
Subject: [PATCH] Use workqueue for scheduler (#194)

---
 schedule.go | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/schedule.go b/schedule.go
index d6dc1462..8b9f53a4 100644
--- a/schedule.go
+++ b/schedule.go
@@ -28,6 +28,7 @@ func NewCmdSchedule() *cobra.Command {
 			PushgatewayURL: "http://stash-operator.kube-system.svc:56789",
 			PodLabelsPath:  "/etc/stash/labels",
 			ResyncPeriod:   5 * time.Minute,
+			MaxNumRequeues: 5,
 		}
 	)
 
@@ -115,7 +116,12 @@ func NewCmdSchedule() *cobra.Command {
 			if err != nil {
 				log.Fatalf("Failed to setup scheduler: %s", err)
 			}
-			ctrl.RunAndHold()
+			stop := make(chan struct{})
+			defer close(stop)
+			go ctrl.Run(1, stop)
+
+			// Wait forever
+			select {}
 		},
 	}
 	cmd.Flags().StringVar(&masterURL, "master", masterURL, "The address of the Kubernetes API server (overrides any value in kubeconfig)")