diff --git a/datastore/threads/threadproxyds.nim b/datastore/threads/threadproxyds.nim
index 2a92056..da58609 100644
--- a/datastore/threads/threadproxyds.nim
+++ b/datastore/threads/threadproxyds.nim
@@ -428,8 +428,8 @@ method query*(
 
     iter.finished = childIter.finished
     var
-      res = ThreadResult[DbQueryResponse]()
-      ctx = TaskCtx[DbQueryResponse](
+      res = ThreadResult[QueryResponse]()
+      ctx = TaskCtx[QueryResponse](
         ds: self.ds,
         res: addr res)