diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 8ad8ba2..67228c8 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -245,6 +245,9 @@ proc queryTask[DB](
   for item in handle.iter():
     executeTask(ctx):
       item
+  
+  executeTask(ctx):
+    (ref QueryEndedError)(msg: "done")
 
 method query*(
   self: ThreadDatastore,