Skip to content

Commit

Permalink
crosscluster/logical: update udf test to expect at-least-once
Browse files Browse the repository at this point in the history
We don't provide exactly once so we don't want to test for it.

Release note: none.
Epic: none.
  • Loading branch information
dt committed Dec 10, 2024
1 parent 1efb255 commit 50f8fe0
Showing 1 changed file with 3 additions and 2 deletions.
5 changes: 3 additions & 2 deletions pkg/crosscluster/logical/udf_row_processor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -188,7 +188,8 @@ func TestUDFPreviousValue(t *testing.T) {
runnerA.Exec(t, "UPDATE tallies SET v = 15 WHERE pk = 1")
WaitUntilReplicatedTime(t, s.Clock().Now(), runnerB, jobBID)

runnerB.CheckQueryResults(t, "SELECT * FROM tallies", [][]string{
{"1", "25"},
// At-least-once delivery means it should be at least 25 (might be 30/35/etc).
runnerB.CheckQueryResults(t, "SELECT v >= 25 FROM tallies", [][]string{
{"true"},
})
}

0 comments on commit 50f8fe0

Please sign in to comment.