Wait for all internal discoveries are done before exiting. (#4508)

Signed-off-by: Yecheng Fu <cofyc.jackson@gmail.com>
2018-08-17 21:20:22 +08:00 · 2018-08-17 21:20:22 +08:00 · d4eae8cc0c
parent a0a9e7df91
commit d4eae8cc0c
1 changed files with 2 additions and 0 deletions
--- a/discovery/kubernetes/kubernetes.go
+++ b/discovery/kubernetes/kubernetes.go
@ -370,6 +370,8 @@ func (d *Discovery) Run(ctx context.Context, ch chan<- []*targetgroup.Group) {
 	}

 	d.Unlock()
+
+	wg.Wait()
 	<-ctx.Done()
 }