@@ -76,7 +76,7 @@ func (c *TestRunner) RemoveTestFromQueue(runID uint64) bool {
7676 return false
7777}
7878
79- func (c * TestRunner ) ScheduleTest (descriptor types.TestDescriptor , configOverrides map [string ]any , allowDuplicate bool , skipQueue bool ) (types.TestRunner , error ) {
79+ func (c * TestRunner ) ScheduleTest (descriptor types.TestDescriptor , configOverrides map [string ]any , allowDuplicate , skipQueue bool ) (types.TestRunner , error ) {
8080 if descriptor .Err () != nil {
8181 return nil , fmt .Errorf ("cannot create test from failed test descriptor: %w" , descriptor .Err ())
8282 }
@@ -98,7 +98,7 @@ func (c *TestRunner) ScheduleTest(descriptor types.TestDescriptor, configOverrid
9898 return testRef , nil
9999}
100100
101- func (c * TestRunner ) createTestRun (descriptor types.TestDescriptor , configOverrides map [string ]any , allowDuplicate bool , skipQueue bool ) (types.TestRunner , error ) {
101+ func (c * TestRunner ) createTestRun (descriptor types.TestDescriptor , configOverrides map [string ]any , allowDuplicate , skipQueue bool ) (types.TestRunner , error ) {
102102 c .testSchedulerMutex .Lock ()
103103 defer c .testSchedulerMutex .Unlock ()
104104
@@ -122,6 +122,7 @@ func (c *TestRunner) createTestRun(descriptor types.TestDescriptor, configOverri
122122 if ! skipQueue {
123123 c .testQueue = append (c .testQueue , testRef )
124124 }
125+
125126 c .testRunMap [runID ] = testRef
126127 c .testRegistryMutex .Unlock ()
127128
@@ -211,6 +212,7 @@ func (c *TestRunner) RunTestScheduler(ctx context.Context) {
211212 // startup scheduler
212213 for _ , testDescr := range c .getStartupTests () {
213214 testConfig := testDescr .Config ()
215+
214216 _ , err := c .ScheduleTest (testDescr , nil , false , testConfig .Schedule .SkipQueue )
215217 if err != nil {
216218 c .coordinator .Logger ().Errorf ("could not schedule startup test execution for %v (%v): %v" , testDescr .ID (), testConfig .Name , err )
@@ -234,6 +236,7 @@ func (c *TestRunner) RunTestScheduler(ctx context.Context) {
234236
235237 for _ , testDescr := range c .getCronTests (cronTime ) {
236238 testConfig := testDescr .Config ()
239+
237240 _ , err := c .ScheduleTest (testDescr , nil , false , testConfig .Schedule .SkipQueue )
238241 if err != nil {
239242 c .coordinator .Logger ().Errorf ("could not schedule cron test execution for %v (%v): %v" , testDescr .ID (), testConfig .Name , err )
0 commit comments