diff --git a/db/db.go b/db/db.go
index 19af83da..50d993bc 100644
--- a/db/db.go
+++ b/db/db.go
@@ -223,8 +223,6 @@ func Process(fib *fibre.Context, ast *sql.Query, vars map[string]interface{}) (o
 
 	executor := newExecutor()
 
-	defer executor.reset()
-
 	go executor.execute(ctx, ast)
 
 	// Wait for all of the processed queries to
diff --git a/db/executor.go b/db/executor.go
index 70565139..ea38f91c 100644
--- a/db/executor.go
+++ b/db/executor.go
@@ -47,13 +47,6 @@ func newExecutor() (e *executor) {
 
 }
 
-func (e *executor) reset() {
-
-	e.send = nil
-	executorPool.Put(e)
-
-}
-
 func (e *executor) execute(ctx context.Context, ast *sql.Query) {
 
 	var err error