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

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

diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 8ad8ba2..67228c8 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -245,6 +245,9 @@ proc queryTask[DB](
   for item in handle.iter():
     executeTask(ctx):
       item
+  
+  executeTask(ctx):
+    (ref QueryEndedError)(msg: "done")
 
 method query*(
   self: ThreadDatastore,