diff --git a/plugins/inputs/dns_query/dns_query.go b/plugins/inputs/dns_query/dns_query.go
index ec524d95b..3f0b1ab2f 100644
--- a/plugins/inputs/dns_query/dns_query.go
+++ b/plugins/inputs/dns_query/dns_query.go
@@ -97,6 +97,8 @@ func (d *DnsQuery) Gather(acc telegraf.Accumulator) error {
 				}
 
 				acc.AddFields("dns_query", fields, tags)
+
+				wg.Done()
 			}(domain, server)
 		}
 	}