diff --git a/datastore/threadproxyds.nim b/datastore/threadproxyds.nim
index 9cdad48..ef843ad 100644
--- a/datastore/threadproxyds.nim
+++ b/datastore/threadproxyds.nim
@@ -211,7 +211,7 @@ proc newThreadProxyDatastore*(
 
   try:
     value[].ds = ds
-    value[].tp = Taskpool.new(num_threads = 2)
+    value[].tp = Taskpool.new(num_threads = 6)
   except Exception as exc:
     return err((ref DatastoreError)(msg: exc.msg))
 
diff --git a/datastore/threads/threadsignalpool.nim b/datastore/threads/threadsignalpool.nim
index b56459c..19d3e21 100644
--- a/datastore/threads/threadsignalpool.nim
+++ b/datastore/threads/threadsignalpool.nim
@@ -103,4 +103,3 @@ proc wait*(sig: SharedSignal): Future[void] =
 
 proc fireSync*(sig: SharedSignal): Result[bool, string] =
   sig[].sigptr.fireSync()
-