diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 055e5d0..a95b9cd 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -245,6 +245,7 @@ proc queryTask[DB](
   var handle = qh.get()
   for item in handle.iter():
     executeTask(ctx):
+      discard ctx[].signal.waitSync().get()
       item
 
   executeTask(ctx):