Fix shutdown tracking in s3 input (#21380) (#21396)

(cherry picked from commit d8d35a1)
elastic · Sep 30, 2020 · 9d5ea60 · 9d5ea60
1 parent 3ad478a
commit 9d5ea60
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/x-pack/filebeat/input/s3/input.go b/x-pack/filebeat/input/s3/input.go
@@ -190,11 +190,11 @@ func (p *s3Input) Run() {
 
  p.workerWg.Add(1)
  go p.run(svcSQS, svcS3, visibilityTimeout)
- p.workerWg.Done()
  })
 }
 
 func (p *s3Input) run(svcSQS sqsiface.ClientAPI, svcS3 s3iface.ClientAPI, visibilityTimeout int64) {
+ defer p.workerWg.Done()
  defer p.logger.Infof("s3 input worker for '%v' has stopped.", p.config.QueueURL)
 
  p.logger.Infof("s3 input worker has started. with queueURL: %v", p.config.QueueURL)