From 85958782440ef7e2972bd9282f09dcb1b33e830e Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 13:02:34 -0700
Subject: [PATCH] setup query

---
 datastore/threads/threadproxyds.nim | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index a752d63..c1a72b1 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -233,7 +233,7 @@ method query*(
     return failure err
 
   let dq = dbQuery(
-    key=query.key,
+    key= KeyId.new query.key.id(),
     value=query.value,
     limit=query.limit,
     offset=query.offset,
@@ -241,7 +241,7 @@ method query*(
   )
 
   dispatchTask[DbQueryResponse[KeyId, DataBuffer]](self, signal):
-    self.tp.spawn deleteTask(addr ctx, ds, dq)
+    self.tp.spawn queryTask(addr ctx, ds, dq)
 
   var
     lock = newAsyncLock() # serialize querying under threads