execute up to two tests concurrently

ethpandaops · Feb 22, 2024 · 3a74706 · 3a74706
1 parent f1a2c8a
commit 3a74706
Showing 1 changed file with 12 additions and 1 deletion.
diff --git a/pkg/coordinator/coordinator.go b/pkg/coordinator/coordinator.go
@@ -267,6 +267,9 @@ func (c *Coordinator) createTestRun(descriptor types.TestDescriptor, configOverr
 }
 
 func (c *Coordinator) runTestExecutionLoop(ctx context.Context) {
+	maxConcurrentTests := 2
+	semaphore := make(chan bool, maxConcurrentTests)
+
 	for {
 		var nextTest types.Test
 
@@ -279,8 +282,16 @@ func (c *Coordinator) runTestExecutionLoop(ctx context.Context) {
 		c.testRegistryMutex.Unlock()
 
 		if nextTest != nil {
+
 			// run next test
-			c.runTest(ctx, nextTest)
+			semaphore <- true
+			go func(nextTest types.Test) {
+				c.runTest(ctx, nextTest)
+				defer func() {
+					<-semaphore
+				}()
+			}(nextTest)
+
 		} else {
 			// sleep and wait for queue notification
 			select {