From 9254b353f0c70f87f1e44011cbfa6ab9bf95a97c Mon Sep 17 00:00:00 2001 From: Lars Lehtonen Date: Thu, 31 Oct 2019 05:23:32 -0700 Subject: [PATCH] nomad: fix test goroutine (#6593) --- nomad/plan_queue_test.go | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/nomad/plan_queue_test.go b/nomad/plan_queue_test.go index beead5dd4..933bd1f39 100644 --- a/nomad/plan_queue_test.go +++ b/nomad/plan_queue_test.go @@ -39,10 +39,15 @@ func TestPlanQueue_Enqueue_Dequeue(t *testing.T) { } resCh := make(chan *structs.PlanResult, 1) + errCh := make(chan error) go func() { + defer close(errCh) + defer close(resCh) + res, err := future.Wait() if err != nil { - t.Fatalf("err: %v", err) + errCh <- err + return } resCh <- res }() @@ -65,6 +70,10 @@ func TestPlanQueue_Enqueue_Dequeue(t *testing.T) { pending.respond(result, nil) select { + case err := <-errCh: + if err != nil { + t.Fatalf("error in anonymous goroutine: %s", err) + } case r := <-resCh: if r != result { t.Fatalf("Bad: %#v", r)