diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index db2c6f1..cf1960e 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -235,9 +235,10 @@ proc queryTask[DB](
       (?!QResult).ok(default(QResult))
     else:
       (?!QResult).err(qh.error())
+  if qh.isErr():
+    return
 
   var handle = qh.get()
-
   for item in handle.iter():
     executeTask(ctx):
       item