Store start time just before installing pipelines (#1791)

mrodm · web-flow · commit 0615df4642e3 · 2024-04-18T18:25:27.000+02:00
diff --git a/internal/testrunner/runners/pipeline/runner.go b/internal/testrunner/runners/pipeline/runner.go
@@ -137,6 +137,7 @@ func (r *runner) run(ctx context.Context) ([]testrunner.TestResult, error) {
 		return nil, errors.New("data stream root not found")
 	}
 
+	startTime := time.Now()
 	var entryPipeline string
 	entryPipeline, r.pipelines, err = ingest.InstallDataStreamPipelines(r.options.API, dataStreamPath)
 	if err != nil {
@@ -176,7 +177,6 @@ func (r *runner) run(ctx context.Context) ([]testrunner.TestResult, error) {
 		expectedDatasets = []string{expectedDataset}
 	}
 
-	startTime := time.Now()
 	results := make([]testrunner.TestResult, 0)
 	for _, testCaseFile := range testCaseFiles {
 		validatorOptions := []fields.ValidatorOption{

Original file line number	Diff line number	Diff line change
`@@ -137,6 +137,7 @@ func (r *runner) run(ctx context.Context) ([]testrunner.TestResult, error) {`
`137`	`137`	`return nil, errors.New("data stream root not found")`
`138`	`138`	`}`
`139`	`139`
	`140`	`+ startTime := time.Now()`
`140`	`141`	`var entryPipeline string`
`141`	`142`	`entryPipeline, r.pipelines, err = ingest.InstallDataStreamPipelines(r.options.API, dataStreamPath)`
`142`	`143`	`if err != nil {`
`@@ -176,7 +177,6 @@ func (r *runner) run(ctx context.Context) ([]testrunner.TestResult, error) {`
`176`	`177`	`expectedDatasets = []string{expectedDataset}`
`177`	`178`	`}`
`178`	`179`
`179`		`- startTime := time.Now()`
`180`	`180`	`results := make([]testrunner.TestResult, 0)`
`181`	`181`	`for _, testCaseFile := range testCaseFiles {`
`182`	`182`	`validatorOptions := []fields.ValidatorOption{`