diff --git a/cmd/pqlogd/main.go b/cmd/pqlogd/main.go
index 3d0efdefb9d823743cb0539c0931fb4efa7da319..fd46c89630be859be837dc780322b8185c779d23 100644
--- a/cmd/pqlogd/main.go
+++ b/cmd/pqlogd/main.go
@@ -59,7 +59,7 @@ func main() {
 	}
 
 	if *enableQuery {
-		qsrv, err := pqhttp.NewQuery(*storageDir)
+		qsrv, err := pqhttp.NewQuery(filepath.Join(*storageDir, "logs.*.pq"))
 		if err != nil {
 			log.Fatal(err)
 		}
diff --git a/http/query.go b/http/query.go
index 555133615e64ec9ee92abc80ca19ca750766ad79..e6f1e7ec23c57a38faea2e7d5fa4bfd3d290f913 100644
--- a/http/query.go
+++ b/http/query.go
@@ -11,7 +11,6 @@ import (
 	"log"
 	"math/rand"
 	"net/http"
-	"path/filepath"
 	"reflect"
 	"strings"
 
@@ -31,13 +30,13 @@ type QueryServer struct {
 	db   *sql.DB
 }
 
-func NewQuery(path string) (*QueryServer, error) {
+func NewQuery(pattern string) (*QueryServer, error) {
 	db, err := sql.Open("duckdb", "")
 	if err != nil {
 		return nil, err
 	}
 	return &QueryServer{
-		glob: filepath.Join(path, "*.pq"),
+		glob: pattern,
 		db:   db,
 	}, nil
 }