Skip to content

Commit

Permalink
Remove conflict rollup ids
Browse files Browse the repository at this point in the history
Signed-off-by: bowenlan-amzn <[email protected]>
  • Loading branch information
bowenlan-amzn committed Oct 1, 2023
1 parent 144a26a commit 285a8eb
Show file tree
Hide file tree
Showing 2 changed files with 3 additions and 3 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -51,7 +51,7 @@ class RestGetRollupActionIT : RollupRestTestCase() {

@Throws(Exception::class)
fun `test getting all rollups`() {
val rollups = randomList(1, 15) { createRollup(randomRollup(), rollupId = "$testName-2") }
val rollups = randomList(1, 15) { createRandomRollup() }

// Using a larger response size than the default in case leftover rollups prevent the ones created in this test from being returned
val res = client().makeRequest("GET", "$ROLLUP_JOBS_BASE_URI?size=100")
Expand Down Expand Up @@ -94,7 +94,7 @@ class RestGetRollupActionIT : RollupRestTestCase() {
fun `test changing response size when getting rollups`() {
// Ensure at least more rollup jobs than the default (20) exists
val rollupCount = 25
repeat(rollupCount) { createRollup(randomRollup(), rollupId = "$testName-3") }
repeat(rollupCount) { createRandomRollup() }

// The default response size is 20, so even though 25 rollup jobs were made, at most 20 will be returned
var res = client().makeRequest("GET", ROLLUP_JOBS_BASE_URI)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -257,7 +257,7 @@ class RestIndexRollupActionIT : RollupRestTestCase() {
}
)
}
val rollup = createRollup(rollup = randomRollup().copy(metrics = metrics), rollupId = "$testName-1")
val rollup = createRollup(rollup = randomRollup().copy(metrics = metrics), rollupId = "$testName-2")
client().makeRequest(
"PUT",
"$ROLLUP_JOBS_BASE_URI/${rollup.id}?refresh=true&if_seq_no=${rollup.seqNo}&if_primary_term=${rollup.primaryTerm}",
Expand Down

0 comments on commit 285a8eb

Please sign in to comment.