diff --git a/plugins/inputs/docker_log/docker_log.go b/plugins/inputs/docker_log/docker_log.go index f2b5b5148..6a675219f 100644 --- a/plugins/inputs/docker_log/docker_log.go +++ b/plugins/inputs/docker_log/docker_log.go @@ -227,7 +227,7 @@ func (d *DockerLogs) Gather(acc telegraf.Accumulator) error { defer d.removeFromContainerList(container.ID) err = d.tailContainerLogs(ctx, acc, container, containerName) - if err != nil { + if err != nil && err != context.Canceled { acc.AddError(err) } }(container)