Skip to content
Merged
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Add check for maximum value of assert.hit_count/min_count
  • Loading branch information
mrodm committed Feb 26, 2025
commit 571330ee7527456e275684d1ccd2bb74a58f580a
8 changes: 8 additions & 0 deletions internal/testrunner/runners/system/tester.go
Original file line number Diff line number Diff line change
Expand Up @@ -1542,6 +1542,14 @@ func (r *tester) waitForDocs(ctx context.Context, config *testConfig, dataStream
waitForDataTimeout = config.WaitForDataTimeout
}

if config.Assert.HitCount >= elasticsearchQuerySize {
return nil, fmt.Errorf("invalid value for assert.hit_count (%d): it must be lower of the maximum query size (%d)", config.Assert.HitCount, elasticsearchQuerySize)
}

if config.Assert.MinCount >= elasticsearchQuerySize {
return nil, fmt.Errorf("invalid value for assert.min_count (%d): it must be lower of the maximum query size (%d)", config.Assert.MinCount, elasticsearchQuerySize)
}

// (TODO in future) Optionally exercise service to generate load.
logger.Debugf("checking for expected data in data stream (%s)...", waitForDataTimeout)
var hits *hits
Expand Down