From 317d42c511e7256f6c2521526534b3724e456d96 Mon Sep 17 00:00:00 2001
From: Jaremy Creechley <creechley@gmail.com>
Date: Tue, 26 Sep 2023 18:47:27 -0700
Subject: [PATCH] test query - it runs!

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

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index a704d40..ed11f18 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -328,9 +328,9 @@ method query*(
   proc next(): Future[?!QueryResponse] {.async.} =
     echo "\n\nquery:next:exec: "
     let ctx = ctx
-    defer:
-      if lock.locked:
-        lock.release()
+    # defer:
+    #   if lock.locked:
+    #     lock.release()
 
     trace "About to query"
     if lock.locked:
@@ -340,9 +340,10 @@ method query*(
       echo "query:next:iter:finished"
       return failure (ref QueryEndedError)(msg: "Calling next on a finished query!")
 
-    echo "query:next:acquire:lock"
-    await lock.acquire()
+    # echo "query:next:acquire:lock"
+    # await lock.acquire()
 
+    echo "query:next:wait:signal"
     await wait(ctx[].signal)
 
     if not ctx[].running: