Fix shutdown tracking in s3 input (elastic#21380)

faec · Sep 29, 2020 · d8d35a1 · d8d35a1
1 parent bb84f3f
commit d8d35a1
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)