sync prometheus ext tests running in parallel

test/extended/prometheus/prometheus.go

@@ -6,6 +6,7 @@ import (
 	"fmt"
 	"strconv"
 	"strings"
+	"sync"
 	"time"
 
 	g "github.com/onsi/ginkgo"
@@ -292,19 +293,25 @@ func waitForServiceAccountInNamespace(c clientset.Interface, ns, serviceAccountN
 	return err
 }
 
+var (
+	processTemplate bool
+	mux             sync.Mutex
+)
+
 func bringUpPrometheusFromTemplate(oc *exutil.CLI) (ns, host, bearerToken string, statsPort int) {
 	ns = oc.KubeFramework().Namespace.Name
 	host = "prometheus.kube-system.svc"
 	statsPort = 443
-	mustCreate := false
+	mux.Lock()
+	defer mux.Unlock()
 	if _, err := oc.AdminKubeClient().Apps().StatefulSets("kube-system").Get("prometheus", metav1.GetOptions{}); err != nil {
 		if !kapierrs.IsNotFound(err) {
 			o.Expect(err).NotTo(o.HaveOccurred())
 		}
-		mustCreate = true
+		processTemplate = true
 	}
 
-	if mustCreate {
+	if processTemplate {
 		e2e.Logf("Installing Prometheus onto the cluster for testing")
 		configPath := exutil.FixturePath("..", "..", "examples", "prometheus", "prometheus.yaml")
 		stdout, _, err := oc.WithoutNamespace().Run("process").Args("-f", configPath).Outputs()