From 7a0c660788a908d0c04ef5de519e1813a3a8d04d Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 13:31:24 -0700
Subject: [PATCH] setup query

---
 datastore/threads/threadproxyds.nim | 21 ++++++++++-----------
 1 file changed, 10 insertions(+), 11 deletions(-)

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 4d068b7..ed2b2de 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -228,20 +228,19 @@ proc queryTask[DB](
     dq: DbQuery[KeyId]
 ) {.gcsafe, nimcall.} =
   ## run query command
-  if not ctx.setRunning():
-    return
-
-  var qh = ds.query(dq)
-  if qh .isOk():
-    (?!QResult).ok(default(QResult))
-  else:
-    (?!QResult).err(qh.error())
+  var qh: typeof(ds.query(dq))
+  executeTask(ctx):
+    qh = ds.query(dq)
+    if qh.isOk():
+      (?!QResult).ok(default(QResult))
+    else:
+      (?!QResult).err(qh.error())
 
   var handle = qh.get()
 
-  for item in 
-  executeTask(ctx):
-    query(ds, key)
+  for item in handle.iter():
+    executeTask(ctx):
+      item
 
 method query*(
   self: ThreadDatastore,