diff --git a/server/querier/engine/clickhouse/client/client.go b/server/querier/engine/clickhouse/client/client.go
index 21b96b7ae67..01a8fc19ce2 100644
--- a/server/querier/engine/clickhouse/client/client.go
+++ b/server/querier/engine/clickhouse/client/client.go
@@ -154,6 +154,7 @@ func (c *Client) DoQuery(params *QueryParams) (result *common.Result, err error)
 	if c.Context == nil {
 		ctx = context.Background()
 	}
+	ctx = clickhouse.Context(ctx, clickhouse.WithQueryID(query_uuid))
 	rows, err := c.connection.Query(ctx, sqlstr)
 	c.Debug.Sql = sqlstr
 	if err != nil {