From 77a147cad27fc4a1dec73b6a6b60170eed9e9168 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 15:09:09 -0700
Subject: [PATCH] setup query end

---
 datastore/threads/threadproxyds.nim | 1 +
 1 file changed, 1 insertion(+)

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):