diff --git a/fluxpipe-server.go b/fluxpipe-server.go
index eefdb51..06a5091 100644
--- a/fluxpipe-server.go
+++ b/fluxpipe-server.go
@@ -155,7 +155,7 @@ func exec(inputString string) (string, error) {
 
 	if q.Err() != nil {
 		fmt.Println("unexpected error from query execution: %s", q.Err())
-		return "", fmt.Errorf(q.Err())
+		return "", q.Err()
 
 	} else {
 		return buf.String(), nil