@@ -397,7 +397,7 @@ func TestDisableChunkTrimmingFuzz(t *testing.T) {
397
397
expr = ps .WalkRangeQuery ()
398
398
query = expr .Pretty (0 )
399
399
// timestamp is a known function that break with disable chunk trimming.
400
- if isValidQuery (expr , 5 , false ) && ! strings .Contains (query , "timestamp" ) {
400
+ if isValidQuery (expr , false ) && ! strings .Contains (query , "timestamp" ) {
401
401
break
402
402
}
403
403
}
@@ -566,7 +566,7 @@ func TestExpandedPostingsCacheFuzz(t *testing.T) {
566
566
matchers := make ([]string , 0 , testRun )
567
567
for i := 0 ; i < testRun ; i ++ {
568
568
expr := ps .WalkRangeQuery ()
569
- if isValidQuery (expr , 5 , true ) {
569
+ if isValidQuery (expr , true ) {
570
570
break
571
571
}
572
572
queries = append (queries , expr .Pretty (0 ))
@@ -1731,7 +1731,7 @@ func runQueryFuzzTestCases(t *testing.T, ps *promqlsmith.PromQLSmith, c1, c2 *e2
1731
1731
for i := 0 ; i < run ; i ++ {
1732
1732
for {
1733
1733
expr = ps .WalkInstantQuery ()
1734
- if isValidQuery (expr , 5 , skipStdAggregations ) {
1734
+ if isValidQuery (expr , skipStdAggregations ) {
1735
1735
query = expr .Pretty (0 )
1736
1736
break
1737
1737
}
@@ -1752,7 +1752,7 @@ func runQueryFuzzTestCases(t *testing.T, ps *promqlsmith.PromQLSmith, c1, c2 *e2
1752
1752
for i := 0 ; i < run ; i ++ {
1753
1753
for {
1754
1754
expr = ps .WalkRangeQuery ()
1755
- if isValidQuery (expr , 5 , skipStdAggregations ) {
1755
+ if isValidQuery (expr , skipStdAggregations ) {
1756
1756
query = expr .Pretty (0 )
1757
1757
break
1758
1758
}
@@ -1803,9 +1803,8 @@ func shouldUseSampleNumComparer(query string) bool {
1803
1803
return false
1804
1804
}
1805
1805
1806
- func isValidQuery (generatedQuery parser.Expr , maxDepth int , skipStdAggregations bool ) bool {
1806
+ func isValidQuery (generatedQuery parser.Expr , skipStdAggregations bool ) bool {
1807
1807
isValid := true
1808
- currentDepth := 0
1809
1808
// TODO(SungJin1212): Test limitk, limit_ratio
1810
1809
if strings .Contains (generatedQuery .String (), "limitk" ) {
1811
1810
// current skip the limitk
@@ -1820,13 +1819,5 @@ func isValidQuery(generatedQuery parser.Expr, maxDepth int, skipStdAggregations
1820
1819
// If skipStdAggregations enabled, we skip to evaluate for stddev and stdvar aggregations.
1821
1820
return false
1822
1821
}
1823
- parser .Inspect (generatedQuery , func (node parser.Node , path []parser.Node ) error {
1824
- if currentDepth > maxDepth {
1825
- isValid = false
1826
- return fmt .Errorf ("generated query has exceeded maxDepth of %d" , maxDepth )
1827
- }
1828
- currentDepth = len (path ) + 1
1829
- return nil
1830
- })
1831
1822
return isValid
1832
1823
}
0 commit comments