Skip to content

Commit 2b26501

Browse files
authored
Merge pull request #125 from linuxboot/fix/step_runner_wait_results_waits_for_finish
2 parents 29d7b6d + 4f2cfed commit 2b26501

1 file changed

Lines changed: 0 additions & 14 deletions

File tree

pkg/runner/step_runner.go

Lines changed: 0 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -237,20 +237,6 @@ func (sr *StepRunner) Started() bool {
237237
// WaitResults returns TestStep.Run() output
238238
// It returns an error if and only if waiting was terminated by inputQueue ctx argument and returns ctx.Err()
239239
func (sr *StepRunner) WaitResults(ctx context.Context) (stepResult StepResult, err error) {
240-
sr.mu.Lock()
241-
resultErr := sr.resultErr
242-
resultResumeState := sr.resultResumeState
243-
sr.mu.Unlock()
244-
245-
// StepRunner either finished with error or behaved incorrectly
246-
// it makes no sense to wait while it finishes, return what we have
247-
if resultErr != nil {
248-
return StepResult{
249-
Err: resultErr,
250-
ResumeState: resultResumeState,
251-
}, nil
252-
}
253-
254240
select {
255241
case <-ctx.Done():
256242
// give priority to returning results

0 commit comments

Comments
 (0)