diff --git a/respodns/dns.py b/respodns/dns.py
index 60566d6..03f5eff 100644
--- a/respodns/dns.py
+++ b/respodns/dns.py
@@ -297,7 +297,6 @@ async def read_all_ips(filepaths, blocking=False, callback=None):
 
 async def main(db, filepaths, checks, ipinfo, opts: Options):
     # ipinfo can be None.
-    from .util import make_pooler
     from asyncio import Queue, QueueFull, create_task
     from queue import SimpleQueue
 
@@ -347,8 +346,10 @@ async def main(db, filepaths, checks, ipinfo, opts: Options):
     await trying
     #lament("AWAITED trying")
 
+    while not deferred.empty():
+        await locate_me.put(deferred.get())
+
     #lament("STOPPING locating")
-    #done_locating.set()
     await locate_me.put(None)
 
     #lament("AWAIT locating")