diff --git a/dune/dune.go b/dune/dune.go
index 15b6961..2a8c665 100644
--- a/dune/dune.go
+++ b/dune/dune.go
@@ -98,7 +98,9 @@ func (c *duneClient) QueryCancel(executionID string) error {
 
 func (c *duneClient) QueryExecute(queryID int, queryParameters map[string]string) (*models.ExecuteResponse, error) {
 	executeURL := fmt.Sprintf(executeURLTemplate, c.env.Host, queryID)
-	jsonData, err := json.Marshal(queryParameters)
+	jsonData, err := json.Marshal(models.ExecuteRequest{
+		QueryParameters: queryParameters,
+	})
 	if err != nil {
 		return nil, err
 	}
diff --git a/models/execute.go b/models/execute.go
index 8efcdb8..39fcdf1 100644
--- a/models/execute.go
+++ b/models/execute.go
@@ -5,6 +5,10 @@ import (
 	"strings"
 )
 
+type ExecuteRequest struct {
+	QueryParameters map[string]string `json:"query_parameters,omitempty"`
+}
+
 type ExecuteResponse struct {
 	ExecutionID string `json:"execution_id,omitempty"`
 	State       string `json:"state,omitempty"`