From d411b561755003721809918d4d7e4111816e3b6b Mon Sep 17 00:00:00 2001 From: Jaremy Creechley Date: Tue, 26 Sep 2023 18:14:30 -0700 Subject: [PATCH] test query --- datastore/threads/threadproxyds.nim | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim index afe69a3..369481c 100644 --- a/datastore/threads/threadproxyds.nim +++ b/datastore/threads/threadproxyds.nim @@ -276,16 +276,15 @@ proc queryTask[DB]( echo "\tqueryTask:query:iter:wait! " discard nextSignal.waitSync().get() - echo "\tqueryTask:query:iter:wait:done " if ctx[].cancelled: echo "\tqueryTask:query:iter:cancelled" # cancel iter, then run next cycle so it'll finish and close handle.cancel = true continue else: - echo "\tqueryTask:query:iter:result:" ctx[].res = item.mapErr() do(exc: ref CatchableError) -> ThreadResErr: exc + echo "\tqueryTask:query:iter:result: ", ctx[].res echo "\tqueryTask:query:iter:fireSync " discard ctx[].signal.fireSync()